org.apache.qpid.server.store

Class AbstractJDBCMessageStore.JDBCTransaction

java.lang.Object

org.apache.qpid.server.store.AbstractJDBCMessageStore.JDBCTransaction

All Implemented Interfaces:

Transaction

Enclosing class:

AbstractJDBCMessageStore

protected class AbstractJDBCMessageStore.JDBCTransaction
extends Object
implements Transaction

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.server.store.Transaction

Transaction.DequeueRecord, Transaction.EnqueueRecord, Transaction.StoredXidRecord

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JDBCTransaction()

Method Summary

Modifier and Type	Method and Description
void	abortTran() Abandons all operations performed within a given transactional context.
void	commitTran() Commits all operations performed within a given transactional context.
<X> com.google.common.util.concurrent.ListenableFuture<X>	commitTranAsync(X val) Commits all operations performed within a given transactional context.
void	dequeueMessage(MessageEnqueueRecord enqueueRecord)
MessageEnqueueRecord	enqueueMessage(TransactionLogResource queue, EnqueueableMessage message) Places a message onto a specified queue, in a given transactional context.
Transaction.StoredXidRecord	recordXid(long format, byte[] globalId, byte[] branchId, Transaction.EnqueueRecord[] enqueues, Transaction.DequeueRecord[] dequeues)
void	removeXid(Transaction.StoredXidRecord record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JDBCTransaction

protected JDBCTransaction()

Method Detail

enqueueMessage

public MessageEnqueueRecord enqueueMessage(TransactionLogResource queue,
                                           EnqueueableMessage message)

Description copied from interface: Transaction

Places a message onto a specified queue, in a given transactional context.

Specified by:

enqueueMessage in interface Transaction

Parameters:

queue - The queue to place the message on.

dequeueMessage

public void dequeueMessage(MessageEnqueueRecord enqueueRecord)

Specified by:

dequeueMessage in interface Transaction

commitTran

public void commitTran()

Description copied from interface: Transaction

Commits all operations performed within a given transactional context.

Specified by:

commitTran in interface Transaction

commitTranAsync

public <X> com.google.common.util.concurrent.ListenableFuture<X> commitTranAsync(X val)

Description copied from interface: Transaction

Commits all operations performed within a given transactional context.

Specified by:

commitTranAsync in interface Transaction

abortTran

public void abortTran()

Description copied from interface: Transaction

Abandons all operations performed within a given transactional context.

Specified by:

abortTran in interface Transaction

removeXid

public void removeXid(Transaction.StoredXidRecord record)

Specified by:

removeXid in interface Transaction

recordXid

public Transaction.StoredXidRecord recordXid(long format,
                                             byte[] globalId,
                                             byte[] branchId,
                                             Transaction.EnqueueRecord[] enqueues,
                                             Transaction.DequeueRecord[] dequeues)

Specified by:

recordXid in interface Transaction