Package | Description |
---|---|
org.apache.qpid.server.exchange | |
org.apache.qpid.server.queue | |
org.apache.qpid.server.txn |
Modifier and Type | Method and Description |
---|---|
ArrayList<BaseQueue> |
FanoutExchange.doRoute(ServerMessage payload,
String routingKey,
InstanceProperties instanceProperties) |
List<? extends BaseQueue> |
DirectExchange.doRoute(ServerMessage payload,
String routingKey,
InstanceProperties instanceProperties) |
ArrayList<BaseQueue> |
TopicExchange.doRoute(ServerMessage payload,
String routingAddress,
InstanceProperties instanceProperties) |
ArrayList<BaseQueue> |
HeadersExchange.doRoute(ServerMessage payload,
String routingKey,
InstanceProperties instanceProperties) |
protected abstract List<? extends BaseQueue> |
AbstractExchange.doRoute(ServerMessage message,
String routingAddress,
InstanceProperties instanceProperties) |
Modifier and Type | Interface and Description |
---|---|
interface |
AMQQueue<X extends AMQQueue<X>> |
interface |
LastValueQueue<X extends LastValueQueue<X>> |
interface |
PriorityQueue<X extends PriorityQueue<X>> |
interface |
SortedQueue<X extends SortedQueue<X>> |
interface |
StandardQueue<X extends StandardQueue<X>> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueue<X extends AbstractQueue<X>> |
class |
LastValueQueueImpl |
class |
OutOfOrderQueue<X extends OutOfOrderQueue<X>> |
class |
PriorityQueueImpl |
class |
SortedQueueImpl |
class |
StandardQueueImpl |
Modifier and Type | Method and Description |
---|---|
void |
AutoCommitTransaction.enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction) |
void |
AsyncAutoCommitTransaction.enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction) |
void |
ServerTransaction.enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction)
Enqueue a message(s) to queue(s) registering a post transaction action.
|
void |
LocalTransaction.enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction) |
void |
DistributedTransaction.enqueue(List<? extends BaseQueue> queues,
EnqueueableMessage message,
ServerTransaction.EnqueueAction postTransactionAction) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.