org.apache.activemq.store
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() |
java.util.Set<java.lang.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.
|
java.util.Map<TransactionId,AMQTx> |
retrievePreparedState() |
void |
savePreparedState(java.util.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 java.io.IOException
destination
- java.io.IOException
TopicReferenceStore createTopicReferenceStore(ActiveMQTopic destination) throws java.io.IOException
destination
- java.io.IOException
java.util.Set<java.lang.Integer> getReferenceFileIdsInUse() throws java.io.IOException
java.io.IOException
boolean isStoreValid()
void clearMessages() throws java.io.IOException
java.io.IOException
void recoverState() throws java.io.IOException
java.io.IOException
void savePreparedState(java.util.Map<TransactionId,AMQTx> map) throws java.io.IOException
map
- java.io.IOException
java.util.Map<TransactionId,AMQTx> retrievePreparedState() throws java.io.IOException
java.io.IOException
long getMaxDataFileLength()
void setMaxDataFileLength(long maxDataFileLength)
maxDataFileLength
- void recoverSubscription(SubscriptionInfo info) throws java.io.IOException
info
- java.io.IOException
Copyright © 2005-2014. All Rights Reserved.