org.apache.qpid.server.txn
Class AutoCommitTransaction
java.lang.Object
org.apache.qpid.server.txn.AutoCommitTransaction
- All Implemented Interfaces:
- ServerTransaction
public class AutoCommitTransaction
- extends Object
- implements ServerTransaction
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AutoCommitTransaction
public AutoCommitTransaction(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> ackedMessages,
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