public class MemoryTransactionStore extends Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
static interface |
MemoryTransactionStore.AddMessageCommand |
static interface |
MemoryTransactionStore.RemoveMessageCommand |
class |
MemoryTransactionStore.Tx |
Constructor and Description |
---|
MemoryTransactionStore(PersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
delete() |
MemoryTransactionStore.Tx |
getTx(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() |
public MemoryTransactionStore(PersistenceAdapter persistenceAdapter)
public MessageStore proxy(MessageStore messageStore)
public TopicMessageStore proxy(TopicMessageStore messageStore)
public void prepare(TransactionId txid)
prepare
in interface TransactionStore
TransactionStore.prepare(TransactionId)
public MemoryTransactionStore.Tx getTx(Object txid)
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
IOException
public void rollback(TransactionId txid)
rollback
in interface TransactionStore
TransactionStore.rollback(TransactionId)
public void start() throws Exception
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
public void delete()
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.