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