public class AsyncAutoCommitTransaction extends Object implements ServerTransaction
Modifier and Type | Class and Description |
---|---|
static interface |
AsyncAutoCommitTransaction.FutureRecorder |
ServerTransaction.Action, ServerTransaction.EnqueueAction
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
_logger |
Constructor and Description |
---|
AsyncAutoCommitTransaction(MessageStore transactionLog,
AsyncAutoCommitTransaction.FutureRecorder recorder) |
Modifier and Type | Method and Description |
---|---|
void |
addPostTransactionAction(ServerTransaction.Action immediateAction)
Since AutoCommitTransaction have no concept of a long lived transaction, any Actions registered
by the caller are executed immediately.
|
void |
commit()
Commit the transaction represented by this object.
|
void |
commit(Runnable immediatePostTransactionAction) |
void |
dequeue(Collection<MessageInstance> queueEntries,
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.
|
public AsyncAutoCommitTransaction(MessageStore transactionLog, AsyncAutoCommitTransaction.FutureRecorder recorder)
public long getTransactionStartTime()
ServerTransaction
getTransactionStartTime
in interface ServerTransaction
public long getTransactionUpdateTime()
ServerTransaction
getTransactionUpdateTime
in interface ServerTransaction
public void addPostTransactionAction(ServerTransaction.Action immediateAction)
addPostTransactionAction
in interface ServerTransaction
public void dequeue(MessageEnqueueRecord record, ServerTransaction.Action postTransactionAction)
ServerTransaction
dequeue
in interface ServerTransaction
public void dequeue(Collection<MessageInstance> queueEntries, ServerTransaction.Action postTransactionAction)
ServerTransaction
dequeue
in interface ServerTransaction
public void enqueue(TransactionLogResource queue, EnqueueableMessage message, ServerTransaction.EnqueueAction postTransactionAction)
ServerTransaction
enqueue
in interface ServerTransaction
public void enqueue(List<? extends BaseQueue> queues, EnqueueableMessage message, ServerTransaction.EnqueueAction postTransactionAction)
ServerTransaction
enqueue
in interface ServerTransaction
public void commit(Runnable immediatePostTransactionAction)
commit
in interface ServerTransaction
public void commit()
ServerTransaction
commit
in interface ServerTransaction
public void rollback()
ServerTransaction
rollback
in interface ServerTransaction
public boolean isTransactional()
isTransactional
in interface ServerTransaction
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.