protected class AbstractJDBCMessageStore.JDBCTransaction extends Object implements Transaction
Transaction.DequeueRecord, Transaction.EnqueueRecord, Transaction.StoredXidRecord
Modifier | Constructor and Description |
---|---|
protected |
JDBCTransaction() |
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) |
public MessageEnqueueRecord enqueueMessage(TransactionLogResource queue, EnqueueableMessage message)
Transaction
enqueueMessage
in interface Transaction
queue
- The queue to place the message on.public void dequeueMessage(MessageEnqueueRecord enqueueRecord)
dequeueMessage
in interface Transaction
public void commitTran()
Transaction
commitTran
in interface Transaction
public <X> com.google.common.util.concurrent.ListenableFuture<X> commitTranAsync(X val)
Transaction
commitTranAsync
in interface Transaction
public void abortTran()
Transaction
abortTran
in interface Transaction
public void removeXid(Transaction.StoredXidRecord record)
removeXid
in interface Transaction
public Transaction.StoredXidRecord recordXid(long format, byte[] globalId, byte[] branchId, Transaction.EnqueueRecord[] enqueues, Transaction.DequeueRecord[] dequeues)
recordXid
in interface Transaction
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.