protected class MessageDatabase.Metadata extends Object
Modifier and Type | Field and 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 |
Modifier | Constructor and Description |
---|---|
protected |
Metadata() |
protected Page<MessageDatabase.Metadata> page
protected int state
protected BTreeIndex<String,org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination> destinations
protected Location lastUpdate
protected Location firstInProgressTransactionLocation
protected Location producerSequenceIdTrackerLocation
protected Location ackMessageFileMapLocation
protected transient ActiveMQMessageAuditNoSync producerSequenceIdTracker
protected transient Map<Integer,Set<Integer>> ackMessageFileMap
protected transient AtomicBoolean ackMessageFileMapDirtyFlag
protected int version
protected int openwireVersion
protected Metadata()
public void read(DataInput is) throws IOException
IOException
public void write(DataOutput os) throws IOException
IOException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.