public class JournalTransactionStore extends Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
static class |
JournalTransactionStore.Tx
Operations
|
static class |
JournalTransactionStore.TxOperation |
Constructor and Description |
---|
JournalTransactionStore(JournalPersistenceAdapter adapter) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(JournalTopicMessageStore store,
JournalTopicAck ack,
org.apache.activeio.journal.RecordLocation location) |
org.apache.activeio.journal.RecordLocation |
checkpoint() |
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
JournalTransactionStore.Tx |
getTx(Object txid,
org.apache.activeio.journal.RecordLocation location) |
boolean |
isDoingRecover() |
void |
prepare(TransactionId txid) |
void |
recover(TransactionRecoveryListener listener) |
void |
removeMessage(JournalMessageStore store,
MessageAck ack,
org.apache.activeio.journal.RecordLocation location) |
JournalTransactionStore.Tx |
replayCommit(TransactionId txid,
boolean wasPrepared) |
void |
replayPrepare(TransactionId txid) |
void |
replayRollback(TransactionId txid) |
void |
rollback(TransactionId txid) |
void |
start() |
void |
stop() |
public JournalTransactionStore(JournalPersistenceAdapter adapter)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
TransactionStore.prepare(TransactionId)
public void replayPrepare(TransactionId txid) throws IOException
IOException
TransactionStore.prepare(TransactionId)
public JournalTransactionStore.Tx getTx(Object txid, org.apache.activeio.journal.RecordLocation location)
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
XAException
IOException
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
public JournalTransactionStore.Tx replayCommit(TransactionId txid, boolean wasPrepared) throws IOException
XAException
IOException
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
TransactionStore.rollback(TransactionId)
public void replayRollback(TransactionId txid) throws IOException
IOException
TransactionStore.rollback(TransactionId)
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
public void removeMessage(JournalMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation location) throws IOException
ack
- IOException
public void acknowledge(JournalTopicMessageStore store, JournalTopicAck ack, org.apache.activeio.journal.RecordLocation location)
public org.apache.activeio.journal.RecordLocation checkpoint() throws IOException
IOException
public boolean isDoingRecover()
Copyright © 2005–2016. All rights reserved.