org.apache.qpid.server.txn
Class LocalTransaction
java.lang.Object
org.apache.qpid.server.txn.LocalTransaction
- All Implemented Interfaces:
- ServerTransaction
public class LocalTransaction
- extends Object
- implements ServerTransaction
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LocalTransaction
public LocalTransaction(TransactionLog transactionLog)
addPostCommitAction
public void addPostCommitAction(ServerTransaction.Action postCommitAction)
- Specified by:
addPostCommitAction
in interface ServerTransaction
dequeue
public void dequeue(BaseQueue queue,
EnqueableMessage message,
ServerTransaction.Action postCommitAction)
- Specified by:
dequeue
in interface ServerTransaction
dequeue
public void dequeue(Collection<QueueEntry> queueEntries,
ServerTransaction.Action postCommitAction)
- Specified by:
dequeue
in interface ServerTransaction
enqueue
public void enqueue(BaseQueue queue,
EnqueableMessage message,
ServerTransaction.Action postCommitAction)
- Specified by:
enqueue
in interface ServerTransaction
enqueue
public void enqueue(List<? extends BaseQueue> queues,
EnqueableMessage message,
ServerTransaction.Action postCommitAction)
- Specified by:
enqueue
in interface ServerTransaction
commit
public void commit()
- Specified by:
commit
in interface ServerTransaction
rollback
public void rollback()
- Specified by:
rollback
in interface ServerTransaction
Licensed to the Apache Software Foundation