org.apache.activemq.store.kahadaptor
public class KahaReferenceStoreAdapter extends KahaPersistenceAdapter implements ReferenceStoreAdapter
messageStores, queues, topics, transactionStore, wireFormat
Constructor and Description |
---|
KahaReferenceStoreAdapter(java.util.concurrent.atomic.AtomicLong size) |
Modifier and Type | Method and Description |
---|---|
protected void |
addSubscriberState(SubscriptionInfo info) |
void |
clearMessages()
called by recover to clear out message references
|
void |
commitTransaction(ConnectionContext context)
Commit a persistence transaction
|
MessageStore |
createQueueMessageStore(ActiveMQQueue destination)
Factory method to create a new queue message store with the given destination name
|
ReferenceStore |
createQueueReferenceStore(ActiveMQQueue destination)
Factory method to create a new queue message store with the given
destination name
|
TopicMessageStore |
createTopicMessageStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination name
|
TopicReferenceStore |
createTopicReferenceStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given
destination name
|
void |
deleteAllMessages()
Delete's all the messages in the persistent store.
|
int |
getIndexBinSize() |
int |
getIndexKeySize() |
int |
getIndexLoadFactor() |
int |
getIndexMaxBinSize() |
int |
getIndexPageSize() |
protected MapContainer<MessageId,ReferenceRecord> |
getMapReferenceContainer(java.lang.Object id,
java.lang.String containerName) |
java.util.Set<java.lang.Integer> |
getReferenceFileIdsInUse() |
protected Store |
getStateStore() |
boolean |
isPersistentIndex() |
boolean |
isStoreValid()
If the store isn't valid, it can be recoverd at start-up
|
void |
recordAckFileReferences(int ackDataFileId,
int messageFileId) |
void |
recoverState()
recover any state
|
void |
recoverSubscription(SubscriptionInfo info)
Recover particular subscription.
|
void |
removeReferenceStore(KahaReferenceStore referenceStore) |
protected void |
removeSubscriberState(SubscriptionInfo info) |
java.util.Map<TransactionId,AMQTx> |
retrievePreparedState() |
void |
savePreparedState(java.util.Map<TransactionId,AMQTx> map)
Save prepared transactions
|
void |
setDirectory(java.io.File directory)
Set the directory where any data files should be created
|
void |
setIndexBinSize(int indexBinSize) |
void |
setIndexKeySize(int indexKeySize) |
void |
setIndexLoadFactor(int loadFactor) |
void |
setIndexMaxBinSize(int maxBinSize) |
void |
setIndexPageSize(int indexPageSize) |
void |
setPersistentIndex(boolean persistentIndex) |
void |
start() |
void |
stop() |
beginTransaction, checkpoint, createMessageMarshaller, createStore, createTransactionStore, getBrokerName, getDestinations, getDirectory, getLastMessageBrokerSequenceId, getLastProducerSequenceId, getListContainer, getMapContainer, getMaxDataFileLength, getStore, getSubsMapContainer, removeQueueMessageStore, removeTopicMessageStore, retrieveMessageStore, rollbackTransaction, setBrokerName, setBrokerService, setMaxDataFileLength, setUsageManager, size, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getMaxDataFileLength, setMaxDataFileLength
beginTransaction, checkpoint, createTransactionStore, getDestinations, getDirectory, getLastMessageBrokerSequenceId, getLastProducerSequenceId, removeQueueMessageStore, removeTopicMessageStore, rollbackTransaction, setBrokerName, setUsageManager, size
public KahaReferenceStoreAdapter(java.util.concurrent.atomic.AtomicLong size)
public MessageStore createQueueMessageStore(ActiveMQQueue destination) throws java.io.IOException
PersistenceAdapter
createQueueMessageStore
in interface PersistenceAdapter
createQueueMessageStore
in class KahaPersistenceAdapter
java.io.IOException
public TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws java.io.IOException
PersistenceAdapter
createTopicMessageStore
in interface PersistenceAdapter
createTopicMessageStore
in class KahaPersistenceAdapter
java.io.IOException
public void start() throws java.lang.Exception
start
in interface Service
start
in class KahaPersistenceAdapter
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class KahaPersistenceAdapter
java.lang.Exception
public void commitTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
commitTransaction
in interface PersistenceAdapter
commitTransaction
in class KahaPersistenceAdapter
java.io.IOException
PersistenceAdapter.beginTransaction(ConnectionContext context)
public boolean isStoreValid()
ReferenceStoreAdapter
isStoreValid
in interface ReferenceStoreAdapter
public ReferenceStore createQueueReferenceStore(ActiveMQQueue destination) throws java.io.IOException
ReferenceStoreAdapter
createQueueReferenceStore
in interface ReferenceStoreAdapter
java.io.IOException
public TopicReferenceStore createTopicReferenceStore(ActiveMQTopic destination) throws java.io.IOException
ReferenceStoreAdapter
createTopicReferenceStore
in interface ReferenceStoreAdapter
java.io.IOException
public void removeReferenceStore(KahaReferenceStore referenceStore)
protected MapContainer<MessageId,ReferenceRecord> getMapReferenceContainer(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
java.io.IOException
public java.util.Set<java.lang.Integer> getReferenceFileIdsInUse() throws java.io.IOException
getReferenceFileIdsInUse
in interface ReferenceStoreAdapter
java.io.IOException
ReferenceStoreAdapter.getReferenceFileIdsInUse()
public void recordAckFileReferences(int ackDataFileId, int messageFileId)
public void clearMessages() throws java.io.IOException
ReferenceStoreAdapter
clearMessages
in interface ReferenceStoreAdapter
java.io.IOException
ReferenceStoreAdapter.clearMessages()
public void recoverState() throws java.io.IOException
ReferenceStoreAdapter
recoverState
in interface ReferenceStoreAdapter
java.io.IOException
ReferenceStoreAdapter.recoverState()
public void recoverSubscription(SubscriptionInfo info) throws java.io.IOException
ReferenceStoreAdapter
recoverSubscription
in interface ReferenceStoreAdapter
java.io.IOException
public java.util.Map<TransactionId,AMQTx> retrievePreparedState() throws java.io.IOException
retrievePreparedState
in interface ReferenceStoreAdapter
java.io.IOException
public void savePreparedState(java.util.Map<TransactionId,AMQTx> map) throws java.io.IOException
ReferenceStoreAdapter
savePreparedState
in interface ReferenceStoreAdapter
java.io.IOException
public void setDirectory(java.io.File directory)
PersistenceAdapter
setDirectory
in interface PersistenceAdapter
setDirectory
in class KahaPersistenceAdapter
protected Store getStateStore() throws java.io.IOException
java.io.IOException
public void deleteAllMessages() throws java.io.IOException
PersistenceAdapter
deleteAllMessages
in interface PersistenceAdapter
deleteAllMessages
in class KahaPersistenceAdapter
java.io.IOException
public boolean isPersistentIndex()
isPersistentIndex
in class KahaPersistenceAdapter
public void setPersistentIndex(boolean persistentIndex)
setPersistentIndex
in class KahaPersistenceAdapter
protected void addSubscriberState(SubscriptionInfo info) throws java.io.IOException
java.io.IOException
protected void removeSubscriberState(SubscriptionInfo info)
public int getIndexBinSize()
public void setIndexBinSize(int indexBinSize)
public int getIndexKeySize()
public void setIndexKeySize(int indexKeySize)
public int getIndexPageSize()
public void setIndexPageSize(int indexPageSize)
public int getIndexMaxBinSize()
public void setIndexMaxBinSize(int maxBinSize)
public int getIndexLoadFactor()
public void setIndexLoadFactor(int loadFactor)
loadFactor
- the loadFactor to setCopyright © 2005-2014. All Rights Reserved.