Package | Description |
---|---|
org.apache.qpid.server.protocol.v0_10 | |
org.apache.qpid.server.protocol.v0_8 | |
org.apache.qpid.server.txn |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.recordFuture(com.google.common.util.concurrent.ListenableFuture<Void> future,
ServerTransaction.Action action) |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.recordFuture(com.google.common.util.concurrent.ListenableFuture<Void> future,
ServerTransaction.Action action) |
Modifier and Type | Method and Description |
---|---|
void |
DtxBranch.addPostTransactionAction(ServerTransaction.Action postTransactionAction) |
void |
AutoCommitTransaction.addPostTransactionAction(ServerTransaction.Action immediateAction)
Since AutoCommitTransaction have no concept of a long lived transaction, any Actions registered
by the caller are executed immediately.
|
void |
AsyncAutoCommitTransaction.addPostTransactionAction(ServerTransaction.Action immediateAction)
Since AutoCommitTransaction have no concept of a long lived transaction, any Actions registered
by the caller are executed immediately.
|
void |
ServerTransaction.addPostTransactionAction(ServerTransaction.Action postTransactionAction)
Register an Action for execution after transaction commit or rollback.
|
void |
LocalTransaction.addPostTransactionAction(ServerTransaction.Action postTransactionAction) |
void |
DistributedTransaction.addPostTransactionAction(ServerTransaction.Action postTransactionAction) |
void |
AutoCommitTransaction.dequeue(Collection<MessageInstance> queueEntries,
ServerTransaction.Action postTransactionAction) |
void |
AsyncAutoCommitTransaction.dequeue(Collection<MessageInstance> queueEntries,
ServerTransaction.Action postTransactionAction) |
void |
ServerTransaction.dequeue(Collection<MessageInstance> messages,
ServerTransaction.Action postTransactionAction)
Dequeue a message(s) from queue(s) registering a post transaction action.
|
void |
LocalTransaction.dequeue(Collection<MessageInstance> queueEntries,
ServerTransaction.Action postTransactionAction) |
void |
DistributedTransaction.dequeue(Collection<MessageInstance> messages,
ServerTransaction.Action postTransactionAction) |
void |
AutoCommitTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
AsyncAutoCommitTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
ServerTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction)
Dequeue a message from a queue registering a post transaction action.
|
void |
LocalTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
DistributedTransaction.dequeue(MessageEnqueueRecord record,
ServerTransaction.Action postTransactionAction) |
void |
AsyncAutoCommitTransaction.FutureRecorder.recordFuture(com.google.common.util.concurrent.ListenableFuture<Void> future,
ServerTransaction.Action action) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.