public interface ReferenceStoreAdapter extends PersistenceAdapter
Modifier and Type | Method and Description |
---|---|
void |
clearMessages()
called by recover to clear out message references
|
ReferenceStore |
createQueueReferenceStore(ActiveMQQueue destination)
Factory method to create a new queue 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
|
long |
getMaxDataFileLength() |
Set<Integer> |
getReferenceFileIdsInUse() |
boolean |
isStoreValid()
If the store isn't valid, it can be recoverd at start-up
|
void |
recoverState()
recover any state
|
void |
recoverSubscription(SubscriptionInfo info)
Recover particular subscription.
|
Map<TransactionId,AMQTx> |
retrievePreparedState() |
void |
savePreparedState(Map<TransactionId,AMQTx> map)
Save prepared transactions
|
void |
setMaxDataFileLength(long maxDataFileLength)
set the max data length of a reference data log - if used
|
beginTransaction, checkpoint, commitTransaction, createQueueMessageStore, createTopicMessageStore, createTransactionStore, deleteAllMessages, getDestinations, getDirectory, getLastMessageBrokerSequenceId, getLastProducerSequenceId, removeQueueMessageStore, removeTopicMessageStore, rollbackTransaction, setBrokerName, setDirectory, setUsageManager, size
ReferenceStore createQueueReferenceStore(ActiveMQQueue destination) throws IOException
destination
- IOException
TopicReferenceStore createTopicReferenceStore(ActiveMQTopic destination) throws IOException
destination
- IOException
Set<Integer> getReferenceFileIdsInUse() throws IOException
IOException
boolean isStoreValid()
void clearMessages() throws IOException
IOException
void recoverState() throws IOException
IOException
void savePreparedState(Map<TransactionId,AMQTx> map) throws IOException
map
- IOException
Map<TransactionId,AMQTx> retrievePreparedState() throws IOException
IOException
long getMaxDataFileLength()
void setMaxDataFileLength(long maxDataFileLength)
maxDataFileLength
- void recoverSubscription(SubscriptionInfo info) throws IOException
info
- IOException
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.