|
||||||||||
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 |
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 |
getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
long |
getLastMessageBrokerSequenceId()
|
boolean |
isUseExternalMessageReferences()
|
void |
rollbackTransaction(ConnectionContext context)
Rollback a persistence transaction |
void |
setUsageManager(UsageManager usageManager)
|
void |
setUseExternalMessageReferences(boolean enable)
|
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
Set getDestinations()
ActiveMQDestination
objects that the persistence store is aware exist.
MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException
IOException
TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException
IOException
TransactionStore createTransactionStore() throws IOException
IOException
void beginTransaction(ConnectionContext context) throws IOException
IOException
void commitTransaction(ConnectionContext context) throws IOException
IOException
PersistenceAdapter#beginTransaction()
void rollbackTransaction(ConnectionContext context) throws IOException
IOException
PersistenceAdapter#beginTransaction()
long getLastMessageBrokerSequenceId() throws IOException
IOException
void deleteAllMessages() throws IOException
IOException
boolean isUseExternalMessageReferences()
void setUseExternalMessageReferences(boolean enable)
void setUsageManager(UsageManager usageManager)
usageManager
- The UsageManager that is controlling the broker's memory usage.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |