org.apache.qpid.server.txn
Class AutoCommitTransaction

java.lang.Object
  extended by org.apache.qpid.server.txn.AutoCommitTransaction
All Implemented Interfaces:
ServerTransaction

public class AutoCommitTransaction
extends Object
implements ServerTransaction


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.txn.ServerTransaction
ServerTransaction.Action
 
Constructor Summary
AutoCommitTransaction(TransactionLog transactionLog)
           
 
Method Summary
 void addPostCommitAction(ServerTransaction.Action postCommitAction)
           
 void commit()
           
 void dequeue(BaseQueue queue, EnqueableMessage message, ServerTransaction.Action postCommitAction)
           
 void dequeue(Collection<QueueEntry> ackedMessages, ServerTransaction.Action postCommitAction)
           
 void enqueue(BaseQueue queue, EnqueableMessage message, ServerTransaction.Action postCommitAction)
           
 void enqueue(List<? extends BaseQueue> queues, EnqueableMessage message, ServerTransaction.Action postCommitAction)
           
 void rollback()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AutoCommitTransaction

public AutoCommitTransaction(TransactionLog transactionLog)
Method Detail

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