|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.filter.DestinationMap
org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
public class MultiKahaDBPersistenceAdapter
An implementation of PersistenceAdapter
that supports
distribution of destinations across multiple kahaDB persistence adapters
Field Summary |
---|
Fields inherited from class org.apache.activemq.filter.DestinationMap |
---|
ANY_CHILD, ANY_DESCENDENT |
Constructor Summary | |
---|---|
MultiKahaDBPersistenceAdapter()
|
Method Summary | |
---|---|
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. |
BrokerService |
getBrokerService()
|
java.util.Set<ActiveMQDestination> |
getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
java.io.File |
getDirectory()
|
int |
getJournalMaxFileLength()
|
int |
getJournalWriteBatchSize()
|
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 |
boolean |
isLocalXid(TransactionId xid)
|
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 |
setBrokerService(BrokerService brokerService)
|
void |
setDirectory(java.io.File directory)
Set the directory where any data files should be created |
void |
setFilteredPersistenceAdapters(java.util.List entries)
Sets the FilteredKahaDBPersistenceAdapter entries |
void |
setJournalMaxFileLength(int maxFileLength)
Set the max file length of the transaction journal When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used |
void |
setJournalWriteBatchSize(int journalWriteBatchSize)
Set the max write batch size of the transaction journal When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used |
void |
setTransactionStore(MultiKahaDBTransactionStore transactionStore)
|
void |
setUsageManager(SystemUsage usageManager)
|
long |
size()
A hint to return the size of the store on disk |
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
Methods inherited from class org.apache.activemq.filter.DestinationMap |
---|
chooseValue, findWildcardMatches, get, getEntryClass, getQueueRootChildCount, getQueueRootNode, getRootNode, getTempQueueRootNode, getTempTopicRootNode, getTopicRootChildCount, getTopicRootNode, put, remove, removeAll, reset, setEntries, union |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public MultiKahaDBPersistenceAdapter()
Method Detail |
---|
public void setFilteredPersistenceAdapters(java.util.List entries)
public boolean isLocalXid(TransactionId xid)
public void beginTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
beginTransaction
in interface PersistenceAdapter
java.io.IOException
public void checkpoint(boolean sync) throws java.io.IOException
PersistenceAdapter
checkpoint
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 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 TransactionStore createTransactionStore() throws java.io.IOException
PersistenceAdapter
createTransactionStore
in interface PersistenceAdapter
java.io.IOException
public 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) throws java.io.IOException
PersistenceAdapter
getLastProducerSequenceId
in interface PersistenceAdapter
id
- the producerId to find a sequenceId for
java.io.IOException
public void removeQueueMessageStore(ActiveMQQueue destination)
PersistenceAdapter
removeQueueMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void removeTopicMessageStore(ActiveMQTopic destination)
PersistenceAdapter
removeTopicMessageStore
in interface PersistenceAdapter
destination
- Destination to forgetpublic void rollbackTransaction(ConnectionContext context) throws java.io.IOException
PersistenceAdapter
rollbackTransaction
in interface PersistenceAdapter
java.io.IOException
PersistenceAdapter.beginTransaction(ConnectionContext context)
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 long size()
PersistenceAdapter
size
in interface PersistenceAdapter
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public java.io.File getDirectory()
getDirectory
in interface PersistenceAdapter
public void setDirectory(java.io.File directory)
PersistenceAdapter
setDirectory
in interface PersistenceAdapter
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
public BrokerService getBrokerService()
public void setTransactionStore(MultiKahaDBTransactionStore transactionStore)
public void setJournalMaxFileLength(int maxFileLength)
public int getJournalMaxFileLength()
public void setJournalWriteBatchSize(int journalWriteBatchSize)
public int getJournalWriteBatchSize()
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |