|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.store.vm.VMPersistenceAdapter
public class VMPersistenceAdapter
Constructor Summary | |
---|---|
VMPersistenceAdapter()
|
Method Summary | |
---|---|
void |
beginTransaction()
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 optimisation. |
void |
commitTransaction()
Commit a persistence transaction |
MessageStore |
createQueueMessageStore(String destinationName)
Factory method to create a new queue message store with the given destination name |
TopicMessageStore |
createTopicMessageStore(String destinationName)
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 |
boolean |
deadLetterAlreadySent(long seq,
boolean useLocking)
Verifies if a dead letter has already been sent for a message |
Map |
getInitialDestinations()
Returns a map, indexed by String name, of all the Destination
objects active on startup. |
static VMPersistenceAdapter |
newInstance(File file)
|
void |
rollbackTransaction()
Rollback a persistence transaction |
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public VMPersistenceAdapter()
Method Detail |
---|
public Map getInitialDestinations()
PersistenceAdapter
Destination
objects active on startup.
getInitialDestinations
in interface PersistenceAdapter
public static VMPersistenceAdapter newInstance(File file)
public MessageStore createQueueMessageStore(String destinationName) throws JMSException
PersistenceAdapter
createQueueMessageStore
in interface PersistenceAdapter
JMSException
public TopicMessageStore createTopicMessageStore(String destinationName) throws JMSException
PersistenceAdapter
createTopicMessageStore
in interface PersistenceAdapter
JMSException
public TransactionStore createTransactionStore() throws JMSException
PersistenceAdapter
createTransactionStore
in interface PersistenceAdapter
JMSException
public void beginTransaction()
PersistenceAdapter
beginTransaction
in interface PersistenceAdapter
public void commitTransaction()
PersistenceAdapter
commitTransaction
in interface PersistenceAdapter
PersistenceAdapter.beginTransaction()
public void rollbackTransaction()
PersistenceAdapter
rollbackTransaction
in interface PersistenceAdapter
PersistenceAdapter.beginTransaction()
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public boolean deadLetterAlreadySent(long seq, boolean useLocking)
deadLetterAlreadySent
in interface PersistenceAdapter
seq
- useLocking
- to prevent concurrency/dups
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |