public class KahaDBStore extends MessageDatabase implements PersistenceAdapter
Modifier and Type | Class and Description |
---|---|
class |
KahaDBStore.KahaDBMessageStore |
MessageDatabase.LastAckMarshaller, MessageDatabase.MessageKeysMarshaller, MessageDatabase.Metadata, MessageDatabase.StoredDestinationMarshaller
Modifier and Type | Field and Description |
---|---|
protected java.util.List<java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,org.apache.activemq.store.kahadb.KahaDBStore.StoreTask>> |
asyncQueueMaps |
protected java.util.List<java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,org.apache.activemq.store.kahadb.KahaDBStore.StoreTask>> |
asyncTopicMaps |
static int |
cancelledTaskModMetric |
static java.lang.String |
PROPERTY_ASYNC_EXECUTOR_MAX_THREADS |
static java.lang.String |
PROPERTY_CANCELED_TASK_MOD_METRIC |
protected java.util.concurrent.ExecutorService |
queueExecutor |
protected java.util.concurrent.ExecutorService |
topicExecutor |
archiveDataLogs, brokerService, checkpointThread, deleteAllMessages, directory, directoryArchive, enableJournalDiskSyncs, failIfDatabaseIsLocked, forceRecoverIndex, indexLock, inflightTransactions, journal, LOG_SLOW_ACCESS_TIME, metadata, metadataMarshaller, opened, pageFile, preparedTransactions, PROPERTY_LOG_SLOW_ACCESS_TIME, storeSize, UNMATCHED
Constructor and Description |
---|
KahaDBStore() |
Modifier and Type | Method and Description |
---|---|
protected void |
addQueueTask(KahaDBStore.KahaDBMessageStore store,
org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask task) |
protected void |
addTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store,
org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask task) |
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.
|
void |
doStart() |
void |
doStop(ServiceStopper stopper) |
java.util.Set<ActiveMQDestination> |
getDestinations()
Returns a set of all the
ActiveMQDestination
objects that the persistence store is aware exist. |
boolean |
getForceRecoverIndex() |
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
|
int |
getMaxAsyncJobs() |
SystemUsage |
getUsageManager() |
boolean |
isConcurrentStoreAndDispatchQueues() |
boolean |
isConcurrentStoreAndDispatchTopics() |
boolean |
isConcurrentStoreAndDispatchTransactions() |
void |
removeQueueMessageStore(ActiveMQQueue destination)
Cleanup method to remove any state associated with the given destination.
|
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask |
removeQueueTask(KahaDBStore.KahaDBMessageStore store,
MessageId id) |
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).
|
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask |
removeTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store,
MessageId id) |
void |
rollbackTransaction(ConnectionContext context)
Rollback a persistence transaction
|
void |
setBrokerName(java.lang.String brokerName)
Set the name of the broker using the adapter
|
void |
setConcurrentStoreAndDispatchQueues(boolean concurrentStoreAndDispatch) |
void |
setConcurrentStoreAndDispatchTopics(boolean concurrentStoreAndDispatch) |
void |
setForceRecoverIndex(boolean forceRecoverIndex) |
void |
setMaxAsyncJobs(int maxAsyncJobs) |
void |
setUsageManager(SystemUsage usageManager) |
long |
size()
A hint to return the size of the store on disk
|
checkpoint, checkpointCleanup, close, getCheckpointInterval, getCleanupInterval, getDatabaseLockedWaitDelay, getDirectory, getDirectoryArchive, getExistingStoredDestination, getFailoverProducersAuditDepth, getFirstInProgressTxLocation, getIndexCacheSize, getIndexWriteBatchSize, getJournal, getJournalFilesBeingReplicated, getJournalMaxFileLength, getJournalMaxWriteBatchSize, getLastUpdatePosition, getLockFile, getMaxFailoverProducersToTrack, getPageFile, getStoredDestination, incrementalRecover, isArchiveDataLogs, isCheckForCorruptJournalFiles, isChecksumJournalFiles, isDeleteAllMessages, isEnableJournalDiskSyncs, isFailIfDatabaseIsLocked, isIgnoreMissingJournalfiles, load, load, open, process, process, process, process, process, process, process, recoverIndex, setArchiveDataLogs, setBrokerService, setCheckForCorruptJournalFiles, setCheckpointInterval, setChecksumJournalFiles, setCleanupInterval, setDatabaseLockedWaitDelay, setDeleteAllMessages, setDirectory, setDirectoryArchive, setEnableIndexWriteAsync, setEnableJournalDiskSyncs, setFailIfDatabaseIsLocked, setFailoverProducersAuditDepth, setIgnoreMissingJournalfiles, setIndexCacheSize, setIndexWriteBatchSize, setJournalMaxFileLength, setJournalMaxWriteBatchSize, setMaxFailoverProducersToTrack, store, store, unload
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setDirectory
public static final java.lang.String PROPERTY_CANCELED_TASK_MOD_METRIC
public static final int cancelledTaskModMetric
public static final java.lang.String PROPERTY_ASYNC_EXECUTOR_MAX_THREADS
protected java.util.concurrent.ExecutorService queueExecutor
protected java.util.concurrent.ExecutorService topicExecutor
protected final java.util.List<java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,org.apache.activemq.store.kahadb.KahaDBStore.StoreTask>> asyncQueueMaps
protected final java.util.List<java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,org.apache.activemq.store.kahadb.KahaDBStore.StoreTask>> asyncTopicMaps
public KahaDBStore()
public void setBrokerName(java.lang.String brokerName)
PersistenceAdapter
setBrokerName
in interface PersistenceAdapter
public void setUsageManager(SystemUsage usageManager)
setUsageManager
in interface PersistenceAdapter
usageManager
- The UsageManager that is controlling the broker's memory usage.public SystemUsage getUsageManager()
public boolean isConcurrentStoreAndDispatchQueues()
public void setConcurrentStoreAndDispatchQueues(boolean concurrentStoreAndDispatch)
concurrentStoreAndDispatch
- the concurrentStoreAndDispatch to setpublic boolean isConcurrentStoreAndDispatchTopics()
public void setConcurrentStoreAndDispatchTopics(boolean concurrentStoreAndDispatch)
concurrentStoreAndDispatch
- the concurrentStoreAndDispatch to setpublic boolean isConcurrentStoreAndDispatchTransactions()
public int getMaxAsyncJobs()
public void setMaxAsyncJobs(int maxAsyncJobs)
maxAsyncJobs
- the maxAsyncJobs to setpublic void doStart() throws java.lang.Exception
doStart
in class MessageDatabase
java.lang.Exception
public void doStop(ServiceStopper stopper) throws java.lang.Exception
doStop
in class MessageDatabase
java.lang.Exception
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask removeQueueTask(KahaDBStore.KahaDBMessageStore store, MessageId id)
protected void addQueueTask(KahaDBStore.KahaDBMessageStore store, org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask task) throws java.io.IOException
java.io.IOException
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask removeTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store, MessageId id)
protected void addTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store, org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask task) throws java.io.IOException
java.io.IOException
public TransactionStore createTransactionStore() throws java.io.IOException
PersistenceAdapter
createTransactionStore
in interface PersistenceAdapter
java.io.IOException
public boolean getForceRecoverIndex()
public void setForceRecoverIndex(boolean forceRecoverIndex)
public MessageStore createQueueMessageStore(ActiveMQQueue destination) throws java.io.IOException
PersistenceAdapter
createQueueMessageStore
in interface PersistenceAdapter
java.io.IOException
public TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws java.io.IOException
PersistenceAdapter
createTopicMessageStore
in interface PersistenceAdapter
java.io.IOException
public void removeQueueMessageStore(ActiveMQQueue destination)
removeQueueMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void removeTopicMessageStore(ActiveMQTopic destination)
removeTopicMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void deleteAllMessages() throws java.io.IOException
PersistenceAdapter
deleteAllMessages
in interface PersistenceAdapter
java.io.IOException
public java.util.Set<ActiveMQDestination> getDestinations()
PersistenceAdapter
ActiveMQDestination
objects that the persistence store is aware exist.getDestinations
in interface PersistenceAdapter
public long getLastMessageBrokerSequenceId() throws java.io.IOException
getLastMessageBrokerSequenceId
in interface PersistenceAdapter
java.io.IOException
public long getLastProducerSequenceId(ProducerId id)
PersistenceAdapter
getLastProducerSequenceId
in interface PersistenceAdapter
id
- the producerId to find a sequenceId forpublic long size()
PersistenceAdapter
size
in interface PersistenceAdapter
public void beginTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
beginTransaction
in interface PersistenceAdapter
java.io.IOException
public void commitTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
commitTransaction
in interface PersistenceAdapter
java.io.IOException
PersistenceAdapter.beginTransaction(ConnectionContext context)
public void rollbackTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
rollbackTransaction
in interface PersistenceAdapter
java.io.IOException
PersistenceAdapter.beginTransaction(ConnectionContext context)
public void checkpoint(boolean sync) throws java.io.IOException
PersistenceAdapter
checkpoint
in interface PersistenceAdapter
java.io.IOException
Copyright © 2005-2012. All Rights Reserved.