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>>
ackMessageFileMap
protected AtomicBoolean
ackMessageFileMapDirtyFlag
protected Location
ackMessageFileMapLocation
protected BTreeIndex<String,org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination>
destinations
protected Location
firstInProgressTransactionLocation
protected Location
lastUpdate
protected int
openwireVersion
protected Page<MessageDatabase.Metadata>
page
protected ActiveMQMessageAuditNoSync
producerSequenceIdTracker
protected Location
producerSequenceIdTrackerLocation
protected int
state
protected int
version
-
Constructor Summary
Constructors Modifier Constructor Description protected
Metadata()
-
-
-
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
-
-