org.apache.activemq.store.memory
Class MemoryTransactionStore

java.lang.Object
  extended by org.apache.activemq.store.memory.MemoryTransactionStore
All Implemented Interfaces:
Service, TransactionStore

public class MemoryTransactionStore
extends java.lang.Object
implements TransactionStore

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

Version:
$Revision: 1.4 $

Nested Class Summary
static interface MemoryTransactionStore.AddMessageCommand
           
static interface MemoryTransactionStore.RemoveMessageCommand
           
static class MemoryTransactionStore.Tx
           
 
Constructor Summary
MemoryTransactionStore()
           
 
Method Summary
 void commit(TransactionId txid, boolean wasPrepared)
           
 void delete()
           
 MemoryTransactionStore.Tx getTx(java.lang.Object txid)
           
 void prepare(TransactionId txid)
           
 MessageStore proxy(MessageStore messageStore)
           
 TopicMessageStore proxy(TopicMessageStore messageStore)
           
 void recover(TransactionRecoveryListener listener)
           
 void rollback(TransactionId txid)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MemoryTransactionStore

public MemoryTransactionStore()
Method Detail

proxy

public MessageStore proxy(MessageStore messageStore)

proxy

public TopicMessageStore proxy(TopicMessageStore messageStore)

prepare

public void prepare(TransactionId txid)
Specified by:
prepare in interface TransactionStore
See Also:
TransactionStore.prepare(TransactionId)

getTx

public MemoryTransactionStore.Tx getTx(java.lang.Object txid)

commit

public void commit(TransactionId txid,
                   boolean wasPrepared)
            throws java.io.IOException
Specified by:
commit in interface TransactionStore
Throws:
javax.transaction.xa.XAException
java.io.IOException
See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)

rollback

public void rollback(TransactionId txid)
Specified by:
rollback in interface TransactionStore
See Also:
TransactionStore.rollback(TransactionId)

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

recover

public void recover(TransactionRecoveryListener listener)
             throws java.io.IOException
Specified by:
recover in interface TransactionStore
Throws:
java.io.IOException

delete

public void delete()


Copyright © 2010 Apache Software Foundation. All Rights Reserved.