|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ReferenceStoreAdapter
Adapter to the actual persistence mechanism used with ActiveMQ
Method Summary | |
---|---|
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 |
Methods inherited from interface org.apache.activemq.store.PersistenceAdapter |
---|
beginTransaction, checkpoint, commitTransaction, createQueueMessageStore, createTopicMessageStore, createTransactionStore, deleteAllMessages, getDestinations, getDirectory, getLastMessageBrokerSequenceId, getLastProducerSequenceId, removeQueueMessageStore, removeTopicMessageStore, rollbackTransaction, setBrokerName, setDirectory, setUsageManager, size |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |