org.apache.activemq.store.memory

Class MemoryTransactionStore

java.lang.Object

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MemoryTransactionStore.AddMessageCommand
static interface	MemoryTransactionStore.RemoveMessageCommand
class	MemoryTransactionStore.Tx

Constructor Summary

Constructors

Constructor and Description
MemoryTransactionStore(PersistenceAdapter persistenceAdapter)

Method Summary

Methods

Modifier and Type	Method and Description
void	commit(TransactionId txid, boolean wasPrepared, java.lang.Runnable preCommit, java.lang.Runnable postCommit)
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(PersistenceAdapter persistenceAdapter)

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,
          java.lang.Runnable preCommit,
          java.lang.Runnable postCommit)
            throws java.io.IOException

Specified by:

commit in interface TransactionStore

Throws:

java.io.IOException

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()