|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
public class KahaPersistenceAdapter
Constructor Summary | |
---|---|
KahaPersistenceAdapter(File dir)
|
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 |
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. |
Set |
getDestinations()
Returns a set of all the ActiveMQDestination
objects that the persistence store is aware exist. |
String |
getIndexType()
|
long |
getLastMessageBrokerSequenceId()
|
protected ListContainer |
getListContainer(Object id,
String containerName)
|
protected MapContainer |
getMapContainer(Object id,
String containerName)
|
long |
getMaxDataFileLength()
|
protected Store |
getStore()
|
boolean |
isUseExternalMessageReferences()
|
protected MessageStore |
retrieveMessageStore(Object id)
|
void |
rollbackTransaction(ConnectionContext context)
Rollback a persistence transaction |
void |
setIndexType(String indexType)
|
void |
setMaxDataFileLength(long maxDataFileLength)
|
void |
setUsageManager(UsageManager usageManager)
|
void |
setUseExternalMessageReferences(boolean useExternalMessageReferences)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public KahaPersistenceAdapter(File dir) throws IOException
IOException
Method Detail |
---|
public Set getDestinations()
PersistenceAdapter
ActiveMQDestination
objects that the persistence store is aware exist.
getDestinations
in interface PersistenceAdapter
public MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException
PersistenceAdapter
createQueueMessageStore
in interface PersistenceAdapter
IOException
public TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException
PersistenceAdapter
createTopicMessageStore
in interface PersistenceAdapter
IOException
protected MessageStore retrieveMessageStore(Object id)
public TransactionStore createTransactionStore() throws IOException
PersistenceAdapter
createTransactionStore
in interface PersistenceAdapter
IOException
public void beginTransaction(ConnectionContext context)
PersistenceAdapter
beginTransaction
in interface PersistenceAdapter
public void commitTransaction(ConnectionContext context) throws IOException
PersistenceAdapter
commitTransaction
in interface PersistenceAdapter
IOException
PersistenceAdapter#beginTransaction()
public void rollbackTransaction(ConnectionContext context)
PersistenceAdapter
rollbackTransaction
in interface PersistenceAdapter
PersistenceAdapter#beginTransaction()
public void start() throws Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
Exception
public long getLastMessageBrokerSequenceId() throws IOException
getLastMessageBrokerSequenceId
in interface PersistenceAdapter
IOException
public void deleteAllMessages() throws IOException
PersistenceAdapter
deleteAllMessages
in interface PersistenceAdapter
IOException
public boolean isUseExternalMessageReferences()
isUseExternalMessageReferences
in interface PersistenceAdapter
public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
setUseExternalMessageReferences
in interface PersistenceAdapter
protected MapContainer getMapContainer(Object id, String containerName) throws IOException
IOException
protected ListContainer getListContainer(Object id, String containerName) throws IOException
IOException
public void setUsageManager(UsageManager usageManager)
setUsageManager
in interface PersistenceAdapter
usageManager
- The UsageManager that is controlling the broker's memory
usage.public long getMaxDataFileLength()
public void setMaxDataFileLength(long maxDataFileLength)
maxDataFileLength
- the maxDataFileLength to setpublic String getIndexType()
public void setIndexType(String indexType)
indexType
- the indexTypes to setprotected Store getStore() throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |