public class LocalTransaction extends Object implements ServerTransaction
Modifier and Type | Class and Description |
---|---|
static interface |
LocalTransaction.ActivityTimeAccessor |
ServerTransaction.Action, ServerTransaction.EnqueueAction
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
_logger |
Constructor and Description |
---|
LocalTransaction(MessageStore transactionLog) |
LocalTransaction(MessageStore transactionLog,
LocalTransaction.ActivityTimeAccessor activityTime) |
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 immediateAction) |
void |
commitAsync(Runnable deferred) |
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.
|
void |
sync() |
public LocalTransaction(MessageStore transactionLog)
public LocalTransaction(MessageStore transactionLog, LocalTransaction.ActivityTimeAccessor activityTime)
public long getTransactionStartTime()
ServerTransaction
getTransactionStartTime
in interface ServerTransaction
public long getTransactionUpdateTime()
ServerTransaction
getTransactionUpdateTime
in interface ServerTransaction
public void addPostTransactionAction(ServerTransaction.Action postTransactionAction)
ServerTransaction
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()
ServerTransaction
commit
in interface ServerTransaction
public void commit(Runnable immediateAction)
commit
in interface ServerTransaction
public void commitAsync(Runnable deferred)
public void rollback()
ServerTransaction
rollback
in interface ServerTransaction
public void sync()
public boolean isTransactional()
isTransactional
in interface ServerTransaction
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.