Modifier and Type | Method and Description |
---|---|
void |
TransactionTimeoutHelper.checkIdleOrOpenTimes(ServerTransaction transaction,
long openWarn,
long openClose,
long idleWarn,
long idleClose) |
Modifier and Type | Method and Description |
---|---|
<M extends ServerMessage<? extends StorableMessageMetaData>> |
DefaultDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractExchange.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Modifier and Type | Method and Description |
---|---|
int |
MessageInstance.routeToAlternate(Action<? super MessageInstance> action,
ServerTransaction txn) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
MessageDestination.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction)
Routes a message
|
Modifier and Type | Method and Description |
---|---|
ServerTransaction |
Session_1_0.getTransaction(Binary transactionId) |
Modifier and Type | Method and Description |
---|---|
Outcome |
NodeReceivingDestination.send(Message_1_0 message,
ServerTransaction txn) |
Outcome |
QueueDestination.send(Message_1_0 message,
ServerTransaction txn) |
Outcome |
ExchangeDestination.send(Message_1_0 message,
ServerTransaction txn) |
Outcome |
ReceivingDestination.send(Message_1_0 message,
ServerTransaction txn) |
Constructor and Description |
---|
TxnCoordinatorLink_1_0(VirtualHostImpl vhost,
Session_1_0 session_1_0,
ReceivingLinkEndpoint endpoint,
LinkedHashMap<Integer,ServerTransaction> openTransactions) |
Modifier and Type | Method and Description |
---|---|
int |
QueueEntryImpl.routeToAlternate(Action<? super MessageInstance> action,
ServerTransaction txn) |
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractQueue.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncAutoCommitTransaction
An implementation of ServerTransaction where each enqueue/dequeue
operation takes place within it own transaction.
|
class |
AutoCommitTransaction
An implementation of ServerTransaction where each enqueue/dequeue
operation takes place within it own transaction.
|
class |
DistributedTransaction |
class |
LocalTransaction
A concrete implementation of ServerTransaction where enqueue/dequeue
operations share a single long-lived transaction.
|
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.