public interface PersistenceAdapter extends Service
Modifier and Type | Method and Description |
---|---|
void |
allowIOResumption() |
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
|
JobSchedulerStore |
createJobSchedulerStore()
Creates and returns a new Job Scheduler store instance.
|
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. |
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(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
|
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
JobSchedulerStore createJobSchedulerStore() throws IOException, UnsupportedOperationException
IOException
- If an error occurs while creating the new JobSchedulerStore.UnsupportedOperationException
- If this adapter does not provide its own
scheduler store implementation.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
- File getDirectory()
void checkpoint(boolean sync) throws IOException
sync
- IOException
long size()
long getLastProducerSequenceId(ProducerId id) throws IOException
id
- the producerId to find a sequenceId forIOException
void allowIOResumption()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.