Package org.apache.activemq.store.kahadb
Class TempKahaDBStore
- java.lang.Object
-
- org.apache.activemq.store.kahadb.TempMessageDatabase
-
- org.apache.activemq.store.kahadb.TempKahaDBStore
-
- All Implemented Interfaces:
BrokerServiceAware
,Service
,PersistenceAdapter
public class TempKahaDBStore extends TempMessageDatabase implements PersistenceAdapter, BrokerServiceAware
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
TempKahaDBStore.KahaDBMessageStore
-
Nested classes/interfaces inherited from class org.apache.activemq.store.kahadb.TempMessageDatabase
TempMessageDatabase.MessageKeysMarshaller, TempMessageDatabase.StoredDestinationMarshaller
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.store.kahadb.TempMessageDatabase
CLOSED_STATE, destinations, directory, indexMutex, inflightTransactions, OPEN_STATE, opened, pageFile, preparedTransactions, started
-
-
Constructor Summary
Constructors Constructor Description TempKahaDBStore()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 anyvoid
commitTransaction(ConnectionContext context)
Commit a persistence transactionJobSchedulerStore
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 nameTopicMessageStore
createTopicMessageStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination nameTransactionStore
createTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recoveryvoid
deleteAllMessages()
Delete's all the messages in the persistent store.Set<ActiveMQDestination>
getDestinations()
Returns a set of all theActiveMQDestination
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 occursvoid
load()
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 transactionvoid
setBrokerName(String brokerName)
Set the name of the broker using the adaptervoid
setBrokerService(BrokerService brokerService)
void
setUsageManager(SystemUsage usageManager)
long
size()
A hint to return the size of the store on disk-
Methods inherited from class org.apache.activemq.store.kahadb.TempMessageDatabase
close, getDirectory, getIndexWriteBatchSize, getJournalFilesBeingReplicated, getPageFile, getStoredDestination, open, process, process, processAdd, processCommit, processPrepare, processRemove, processRollback, setDirectory, setEnableIndexWriteAsync, setIndexWriteBatchSize, start, stop, unload
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.activemq.store.PersistenceAdapter
getDirectory, setDirectory
-
-
-
-
Method Detail
-
setBrokerName
public void setBrokerName(String brokerName)
Description copied from interface:PersistenceAdapter
Set the name of the broker using the adapter- Specified by:
setBrokerName
in interfacePersistenceAdapter
-
setUsageManager
public void setUsageManager(SystemUsage usageManager)
- Specified by:
setUsageManager
in interfacePersistenceAdapter
- Parameters:
usageManager
- The UsageManager that is controlling the broker's memory usage.
-
createTransactionStore
public TransactionStore createTransactionStore() throws IOException
Description copied from interface:PersistenceAdapter
Factory method to create a new persistent prepared transaction store for XA recovery- Specified by:
createTransactionStore
in interfacePersistenceAdapter
- Returns:
- transaction store
- Throws:
IOException
-
createQueueMessageStore
public MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException
Description copied from interface:PersistenceAdapter
Factory method to create a new queue message store with the given destination name- Specified by:
createQueueMessageStore
in interfacePersistenceAdapter
- Returns:
- the message store
- Throws:
IOException
-
createTopicMessageStore
public TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException
Description copied from interface:PersistenceAdapter
Factory method to create a new topic message store with the given destination name- Specified by:
createTopicMessageStore
in interfacePersistenceAdapter
- Returns:
- the topic message store
- Throws:
IOException
-
removeQueueMessageStore
public void removeQueueMessageStore(ActiveMQQueue 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).- Specified by:
removeQueueMessageStore
in interfacePersistenceAdapter
- Parameters:
destination
- Destination to forget
-
removeTopicMessageStore
public 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).- Specified by:
removeTopicMessageStore
in interfacePersistenceAdapter
- Parameters:
destination
- Destination to forget
-
deleteAllMessages
public void deleteAllMessages() throws IOException
Description copied from interface:PersistenceAdapter
Delete's all the messages in the persistent store.- Specified by:
deleteAllMessages
in interfacePersistenceAdapter
- Throws:
IOException
-
getDestinations
public Set<ActiveMQDestination> getDestinations()
Description copied from interface:PersistenceAdapter
Returns a set of all theActiveMQDestination
objects that the persistence store is aware exist.- Specified by:
getDestinations
in interfacePersistenceAdapter
- Returns:
- active destinations
-
getLastMessageBrokerSequenceId
public long getLastMessageBrokerSequenceId() throws IOException
- Specified by:
getLastMessageBrokerSequenceId
in interfacePersistenceAdapter
- Returns:
- last broker sequence
- Throws:
IOException
-
size
public long size()
Description copied from interface:PersistenceAdapter
A hint to return the size of the store on disk- Specified by:
size
in interfacePersistenceAdapter
- Returns:
- disk space used in bytes of 0 if not implemented
-
beginTransaction
public void beginTransaction(ConnectionContext context) throws IOException
Description copied from interface:PersistenceAdapter
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. Typically one transaction will require one disk synchronization point and so for real high performance its usually faster to perform many writes within the same transaction to minimize latency caused by disk synchronization. This is especially true when using tools like Berkeley Db or embedded JDBC servers.- Specified by:
beginTransaction
in interfacePersistenceAdapter
- Throws:
IOException
-
commitTransaction
public void commitTransaction(ConnectionContext context) throws IOException
Description copied from interface:PersistenceAdapter
Commit a persistence transaction- Specified by:
commitTransaction
in interfacePersistenceAdapter
- Throws:
IOException
- See Also:
PersistenceAdapter.beginTransaction(ConnectionContext context)
-
rollbackTransaction
public void rollbackTransaction(ConnectionContext context) throws IOException
Description copied from interface:PersistenceAdapter
Rollback a persistence transaction- Specified by:
rollbackTransaction
in interfacePersistenceAdapter
- Throws:
IOException
- See Also:
PersistenceAdapter.beginTransaction(ConnectionContext context)
-
checkpoint
public void checkpoint(boolean sync) throws IOException
Description copied from interface:PersistenceAdapter
checkpoint any- Specified by:
checkpoint
in interfacePersistenceAdapter
- Throws:
IOException
-
getLastProducerSequenceId
public long getLastProducerSequenceId(ProducerId id)
Description copied from interface:PersistenceAdapter
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- Specified by:
getLastProducerSequenceId
in interfacePersistenceAdapter
- Parameters:
id
- the producerId to find a sequenceId for- Returns:
- the last stored sequence id or -1 if no suppression needed
-
allowIOResumption
public void allowIOResumption()
- Specified by:
allowIOResumption
in interfacePersistenceAdapter
-
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interfaceBrokerServiceAware
-
load
public void load() throws IOException
- Overrides:
load
in classTempMessageDatabase
- Throws:
IOException
-
createJobSchedulerStore
public JobSchedulerStore createJobSchedulerStore() throws IOException, UnsupportedOperationException
Description copied from interface:PersistenceAdapter
Creates and returns a new Job Scheduler store instance.- Specified by:
createJobSchedulerStore
in interfacePersistenceAdapter
- Returns:
- a new JobSchedulerStore instance if this Persistence adapter provides its own.
- Throws:
IOException
- If an error occurs while creating the new JobSchedulerStore.UnsupportedOperationException
- If this adapter does not provide its own scheduler store implementation.
-
-