org.activemq.store.vm
Class VMTransactionStore

java.lang.Object
  extended by org.activemq.store.vm.VMTransactionStore
All Implemented Interfaces:
Service, TransactionStore

public class VMTransactionStore
extends Object
implements TransactionStore

Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.

Version:
$Revision: 1.1.1.1 $

Nested Class Summary
static interface VMTransactionStore.AddMessageCommand
           
static interface VMTransactionStore.RemoveMessageCommand
           
static class VMTransactionStore.Tx
           
 
Nested classes/interfaces inherited from interface org.activemq.store.TransactionStore
TransactionStore.RecoveryListener
 
Constructor Summary
VMTransactionStore()
           
 
Method Summary
 void commit(Object txid, boolean wasPrepared)
           
 VMTransactionStore.Tx getTx(Object txid)
           
 void prepare(Object txid)
           
 MessageStore proxy(MessageStore messageStore)
           
 TopicMessageStore proxy(TopicMessageStore messageStore)
           
 void recover(TransactionStore.RecoveryListener listener)
           
 void rollback(Object txid)
           
 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

VMTransactionStore

public VMTransactionStore()
Method Detail

proxy

public MessageStore proxy(MessageStore messageStore)

proxy

public TopicMessageStore proxy(TopicMessageStore messageStore)

prepare

public void prepare(Object txid)
Specified by:
prepare in interface TransactionStore
See Also:
org.activemq.store.TransactionStore#prepare(org.activemq.service.Transaction)

getTx

public VMTransactionStore.Tx getTx(Object txid)

commit

public void commit(Object txid,
                   boolean wasPrepared)
            throws XAException
Specified by:
commit in interface TransactionStore
Throws:
XAException
See Also:
org.activemq.store.TransactionStore#commit(org.activemq.service.Transaction)

rollback

public void rollback(Object txid)
Specified by:
rollback in interface TransactionStore
See Also:
org.activemq.store.TransactionStore#rollback(org.activemq.service.Transaction)

start

public void start()
           throws JMSException
Description copied from interface: Service
Called to start the service

Specified by:
start in interface Service
Throws:
JMSException

stop

public void stop()
          throws JMSException
Description copied from interface: Service
Called to shutdown the service

Specified by:
stop in interface Service
Throws:
JMSException

recover

public void recover(TransactionStore.RecoveryListener listener)
             throws XAException
Specified by:
recover in interface TransactionStore
Throws:
XAException


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.