|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PersistenceAdapter
Adapter to the actual persistence mechanism used with ActiveMQ
Method Summary | |
---|---|
void |
beginTransaction(ConnectionContext context)
This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimization. |
void |
checkpoint(boolean sync)
checkpoint any |
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 |
TopicMessageStore |
createTopicMessageStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination name |
TransactionStore |
createTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recovery |
void |
deleteAllMessages()
Delete's all the messages in the persistent store. |
Set<ActiveMQDestination> |
getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
long |
getLastMessageBrokerSequenceId()
|
void |
removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination. |
void |
removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination This method does not stop the message store (it might not be cached). |
void |
rollbackTransaction(ConnectionContext context)
Rollback a persistence transaction |
void |
setBrokerName(String brokerName)
Set the name of the broker using the adapter |
void |
setDirectory(File dir)
Set the directory where any data files should be created |
void |
setUsageManager(SystemUsage usageManager)
|
long |
size()
A hint to return the size of the store on disk |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
Set<ActiveMQDestination> getDestinations()
ActiveMQDestination
objects that the persistence store is aware exist.
MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException
destination
-
IOException
TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException
destination
-
IOException
void removeQueueMessageStore(ActiveMQQueue destination)
destination
- Destination to forgetvoid removeTopicMessageStore(ActiveMQTopic destination)
destination
- Destination to forgetTransactionStore createTransactionStore() throws IOException
IOException
void beginTransaction(ConnectionContext context) throws IOException
context
-
IOException
void commitTransaction(ConnectionContext context) throws IOException
context
-
IOException
beginTransaction(ConnectionContext context)
void rollbackTransaction(ConnectionContext context) throws IOException
context
-
IOException
beginTransaction(ConnectionContext context)
long getLastMessageBrokerSequenceId() throws IOException
IOException
void deleteAllMessages() throws IOException
IOException
void setUsageManager(SystemUsage usageManager)
usageManager
- The UsageManager that is controlling the broker's memory usage.void setBrokerName(String brokerName)
brokerName
- void setDirectory(File dir)
dir
- void checkpoint(boolean sync) throws IOException
sync
-
IOException
long size()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |