public interface ServerTransaction
Modifier and Type | Interface and Description |
---|---|
static interface |
ServerTransaction.Action
Represents an action to be performed on transaction commit or rollback
|
static interface |
ServerTransaction.EnqueueAction |
Modifier and Type | Method and Description |
---|---|
void |
addPostTransactionAction(ServerTransaction.Action postTransactionAction)
Register an Action for execution after transaction commit or rollback.
|
void |
commit()
Commit the transaction represented by this object.
|
void |
commit(Runnable immediatePostTransactionAction) |
void |
dequeue(Collection<MessageInstance> messages,
ServerTransaction.Action postTransactionAction)
Dequeue a message(s) from queue(s) registering a post transaction action.
|
void |
dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction)
Dequeue a message from a queue registering a post transaction action.
|
void |
enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction)
Enqueue a message(s) to queue(s) registering a post transaction action.
|
void |
enqueue(TransactionLogResource queue,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction)
Enqueue a message to a queue registering a post transaction action.
|
long |
getTransactionStartTime()
Return the time the current transaction started.
|
long |
getTransactionUpdateTime()
Return the time of the last activity on the current transaction.
|
boolean |
isTransactional() |
void |
rollback()
Rollback the transaction represented by this object.
|
long getTransactionStartTime()
long getTransactionUpdateTime()
void addPostTransactionAction(ServerTransaction.Action postTransactionAction)
void dequeue(MessageEnqueueRecord record, ServerTransaction.Action postTransactionAction)
void dequeue(Collection<MessageInstance> messages, ServerTransaction.Action postTransactionAction)
void enqueue(TransactionLogResource queue, EnqueueableMessage message, ServerTransaction.EnqueueAction postTransactionAction)
void enqueue(List<? extends BaseQueue> queues, EnqueueableMessage message, ServerTransaction.EnqueueAction postTransactionAction)
void commit()
void commit(Runnable immediatePostTransactionAction)
void rollback()
boolean isTransactional()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.