org.apache.qpid.server.store
Interface TransactionLog.Transaction

Enclosing interface:
TransactionLog

public static interface TransactionLog.Transaction


Method Summary
 void abortTran()
          Abandons all operations performed within a given transactional context.
 void commitTran()
          Commits all operations performed within a given transactional context.
 TransactionLog.StoreFuture commitTranAsync()
          Commits all operations performed within a given transactional context.
 void dequeueMessage(TransactionLogResource queue, Long messageId)
          Extracts a message from a specified queue, in a given transactional context.
 void enqueueMessage(TransactionLogResource queue, Long messageId)
          Places a message onto a specified queue, in a given transactional context.
 

Method Detail

enqueueMessage

void enqueueMessage(TransactionLogResource queue,
                    Long messageId)
                    throws org.apache.qpid.AMQStoreException
Places a message onto a specified queue, in a given transactional context.

Parameters:
queue - The queue to place the message on.
messageId - The message to enqueue.
Throws:
org.apache.qpid.AMQStoreException - If the operation fails for any reason.

dequeueMessage

void dequeueMessage(TransactionLogResource queue,
                    Long messageId)
                    throws org.apache.qpid.AMQStoreException
Extracts a message from a specified queue, in a given transactional context.

Parameters:
queue - The queue to place the message on.
messageId - The message to dequeue.
Throws:
org.apache.qpid.AMQStoreException - If the operation fails for any reason, or if the specified message does not exist.

commitTran

void commitTran()
                throws org.apache.qpid.AMQStoreException
Commits all operations performed within a given transactional context.

Throws:
org.apache.qpid.AMQStoreException - If the operation fails for any reason.

commitTranAsync

TransactionLog.StoreFuture commitTranAsync()
                                           throws org.apache.qpid.AMQStoreException
Commits all operations performed within a given transactional context.

Throws:
org.apache.qpid.AMQStoreException - If the operation fails for any reason.

abortTran

void abortTran()
               throws org.apache.qpid.AMQStoreException
Abandons all operations performed within a given transactional context.

Throws:
org.apache.qpid.AMQStoreException - If the operation fails for any reason.


Licensed to the Apache Software Foundation