org.apache.activemq.store

Interface TransactionStore

All Superinterfaces:

Service

All Known Implementing Classes:

org.apache.activemq.leveldb.replicated.ElectingLevelDBStore, JdbcMemoryTransactionStore, JournalTransactionStore, KahaDBTransactionStore, LevelDBPersistenceAdapter, org.apache.activemq.leveldb.LevelDBStore, MemoryTransactionStore, MultiKahaDBTransactionStore, org.apache.activemq.leveldb.replicated.ProxyLevelDBStore, ReplicatedLevelDBPersistenceAdapter

public interface TransactionStore
extends Service

Represents the durable store of the commit/rollback operations taken against the broker.

Method Summary

Methods

Modifier and Type	Method and Description
void	commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit)
void	prepare(TransactionId txid)
void	recover(TransactionRecoveryListener listener)
void	rollback(TransactionId txid)

Methods inherited from interface org.apache.activemq.Service

start, stop

Method Detail

prepare

void prepare(TransactionId txid)
             throws IOException

Throws:

IOException

commit

void commit(TransactionId txid,
          boolean wasPrepared,
          Runnable preCommit,
          Runnable postCommit)
            throws IOException

Throws:

IOException

rollback

void rollback(TransactionId txid)
              throws IOException

Throws:

IOException

recover

void recover(TransactionRecoveryListener listener)
             throws IOException

Throws:

IOException