|
||||||||||
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. |
java.util.Set<ActiveMQDestination> |
getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
long |
getLastMessageBrokerSequenceId()
|
long |
getLastProducerSequenceId(ProducerId id)
return the last stored producer sequenceId for this producer Id used to suppress duplicate sends on failover reconnect at the transport when a reconnect occurs |
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(java.lang.String brokerName)
Set the name of the broker using the adapter |
void |
setDirectory(java.io.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 |
---|
java.util.Set<ActiveMQDestination> getDestinations()
ActiveMQDestination
objects that the persistence store is aware exist.
MessageStore createQueueMessageStore(ActiveMQQueue destination) throws java.io.IOException
destination
-
java.io.IOException
TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws java.io.IOException
destination
-
java.io.IOException
void removeQueueMessageStore(ActiveMQQueue destination)
destination
- Destination to forgetvoid removeTopicMessageStore(ActiveMQTopic destination)
destination
- Destination to forgetTransactionStore createTransactionStore() throws java.io.IOException
java.io.IOException
void beginTransaction(ConnectionContext context) throws java.io.IOException
context
-
java.io.IOException
void commitTransaction(ConnectionContext context) throws java.io.IOException
context
-
java.io.IOException
beginTransaction(ConnectionContext context)
void rollbackTransaction(ConnectionContext context) throws java.io.IOException
context
-
java.io.IOException
beginTransaction(ConnectionContext context)
long getLastMessageBrokerSequenceId() throws java.io.IOException
java.io.IOException
void deleteAllMessages() throws java.io.IOException
java.io.IOException
void setUsageManager(SystemUsage usageManager)
usageManager
- The UsageManager that is controlling the broker's memory usage.void setBrokerName(java.lang.String brokerName)
brokerName
- void setDirectory(java.io.File dir)
dir
- void checkpoint(boolean sync) throws java.io.IOException
sync
-
java.io.IOException
long size()
long getLastProducerSequenceId(ProducerId id) throws java.io.IOException
id
- the producerId to find a sequenceId for
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |