Package org.apache.activemq.store.kahadb
Class MessageDatabase.Metadata
- java.lang.Object
-
- org.apache.activemq.store.kahadb.MessageDatabase.Metadata
-
- Enclosing class:
- MessageDatabase
protected class MessageDatabase.Metadata extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected Map<Integer,Set<Integer>>ackMessageFileMapprotected AtomicBooleanackMessageFileMapDirtyFlagprotected LocationackMessageFileMapLocationprotected BTreeIndex<String,org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination>destinationsprotected LocationfirstInProgressTransactionLocationprotected LocationlastUpdateprotected intopenwireVersionprotected Page<MessageDatabase.Metadata>pageprotected ActiveMQMessageAuditNoSyncproducerSequenceIdTrackerprotected LocationproducerSequenceIdTrackerLocationprotected intstateprotected intversion
-
Constructor Summary
Constructors Modifier Constructor Description protectedMetadata()
-
-
-
Field Detail
-
page
protected Page<MessageDatabase.Metadata> page
-
state
protected int state
-
destinations
protected BTreeIndex<String,org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination> destinations
-
lastUpdate
protected Location lastUpdate
-
firstInProgressTransactionLocation
protected Location firstInProgressTransactionLocation
-
producerSequenceIdTrackerLocation
protected Location producerSequenceIdTrackerLocation
-
ackMessageFileMapLocation
protected Location ackMessageFileMapLocation
-
producerSequenceIdTracker
protected transient ActiveMQMessageAuditNoSync producerSequenceIdTracker
-
ackMessageFileMapDirtyFlag
protected transient AtomicBoolean ackMessageFileMapDirtyFlag
-
version
protected int version
-
openwireVersion
protected int openwireVersion
-
-
Method Detail
-
read
public void read(DataInput is) throws IOException
- Throws:
IOException
-
write
public void write(DataOutput os) throws IOException
- Throws:
IOException
-
-