public class TempKahaDBStore extends TempMessageDatabase implements PersistenceAdapter, BrokerServiceAware
Modifier and Type | Class and Description |
---|---|
class |
TempKahaDBStore.KahaDBMessageStore |
TempMessageDatabase.MessageKeysMarshaller, TempMessageDatabase.StoredDestinationMarshaller
CLOSED_STATE, destinations, directory, indexMutex, inflightTransactions, OPEN_STATE, opened, pageFile, preparedTransactions, started
Constructor and Description |
---|
TempKahaDBStore() |
Modifier and Type | Method and Description |
---|---|
void |
allowIOResumption() |
void |
beginTransaction(ConnectionContext context) |
void |
checkpoint(boolean sync) |
void |
commitTransaction(ConnectionContext context) |
JobSchedulerStore |
createJobSchedulerStore() |
MessageStore |
createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination) |
TopicMessageStore |
createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic destination) |
TransactionStore |
createTransactionStore() |
void |
deleteAllMessages() |
Set<org.apache.activemq.command.ActiveMQDestination> |
getDestinations() |
long |
getLastMessageBrokerSequenceId() |
long |
getLastProducerSequenceId(org.apache.activemq.command.ProducerId id) |
void |
load() |
void |
removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination.
|
void |
removeTopicMessageStore(org.apache.activemq.command.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) |
void |
setBrokerName(String brokerName) |
void |
setBrokerService(BrokerService brokerService) |
void |
setUsageManager(SystemUsage usageManager) |
long |
size() |
close, getDirectory, getIndexWriteBatchSize, getJournalFilesBeingReplicated, getPageFile, getStoredDestination, open, process, process, processAdd, processCommit, processPrepare, processRemove, processRollback, setDirectory, setEnableIndexWriteAsync, setIndexWriteBatchSize, start, stop, unload
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDirectory, setDirectory
public TempKahaDBStore()
public void setBrokerName(String brokerName)
setBrokerName
in interface PersistenceAdapter
public void setUsageManager(SystemUsage usageManager)
setUsageManager
in interface PersistenceAdapter
public TransactionStore createTransactionStore() throws IOException
createTransactionStore
in interface PersistenceAdapter
IOException
public MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination) throws IOException
createQueueMessageStore
in interface PersistenceAdapter
IOException
public TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic destination) throws IOException
createTopicMessageStore
in interface PersistenceAdapter
IOException
public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination)
removeQueueMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic destination)
removeTopicMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void deleteAllMessages() throws IOException
deleteAllMessages
in interface PersistenceAdapter
IOException
public Set<org.apache.activemq.command.ActiveMQDestination> getDestinations()
getDestinations
in interface PersistenceAdapter
public long getLastMessageBrokerSequenceId() throws IOException
getLastMessageBrokerSequenceId
in interface PersistenceAdapter
IOException
public long size()
size
in interface PersistenceAdapter
public void beginTransaction(ConnectionContext context) throws IOException
beginTransaction
in interface PersistenceAdapter
IOException
public void commitTransaction(ConnectionContext context) throws IOException
commitTransaction
in interface PersistenceAdapter
IOException
public void rollbackTransaction(ConnectionContext context) throws IOException
rollbackTransaction
in interface PersistenceAdapter
IOException
public void checkpoint(boolean sync) throws IOException
checkpoint
in interface PersistenceAdapter
IOException
public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId id)
getLastProducerSequenceId
in interface PersistenceAdapter
public void allowIOResumption()
allowIOResumption
in interface PersistenceAdapter
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
public void load() throws IOException
load
in class TempMessageDatabase
IOException
public JobSchedulerStore createJobSchedulerStore() throws IOException, UnsupportedOperationException
createJobSchedulerStore
in interface PersistenceAdapter
IOException
UnsupportedOperationException
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.