org.apache.activemq.store
public interface PersistenceAdapter extends Service
Modifier and Type | Method and Description |
---|---|
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. |
java.io.File |
getDirectory() |
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
|
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
- java.io.File getDirectory()
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 forjava.io.IOException
Copyright © 2005-2014. All Rights Reserved.