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) |
<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 |
---|---|
static Filterable |
Filterable.Factory.newInstance(ServerMessage message,
InstanceProperties properties) |
Modifier and Type | Field and Description |
---|---|
static InstanceProperties |
InstanceProperties.EMPTY |
Modifier and Type | Method and Description |
---|---|
static InstanceProperties |
InstanceProperties.Factory.copy(InstanceProperties from) |
static InstanceProperties |
InstanceProperties.Factory.fromMap(Map<InstanceProperties.Property,Object> map) |
InstanceProperties |
MessageInstance.getInstanceProperties() |
Modifier and Type | Method and Description |
---|---|
static Map<InstanceProperties.Property,Object> |
InstanceProperties.Factory.asMap(InstanceProperties props) |
static InstanceProperties |
InstanceProperties.Factory.copy(InstanceProperties from) |
<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 |
---|---|
int |
ServerSession.enqueue(MessageTransferMessage message,
InstanceProperties instanceProperties,
MessageDestination exchange) |
Modifier and Type | Method and Description |
---|---|
long |
AMQPConnection_0_8.WriteDeliverMethod.deliverToClient(ConsumerImpl sub,
ServerMessage message,
InstanceProperties props,
long deliveryTag) |
long |
ClientDeliveryMethod.deliverToClient(ConsumerImpl sub,
ServerMessage message,
InstanceProperties props,
long deliveryTag) |
protected long |
ConsumerTarget_0_8.sendToClient(ConsumerImpl consumer,
ServerMessage message,
InstanceProperties props,
long deliveryTag) |
long |
ProtocolOutputConverterImpl.writeDeliver(ServerMessage m,
InstanceProperties props,
int channelId,
long deliveryTag,
AMQShortString consumerTag) |
long |
ProtocolOutputConverter.writeDeliver(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
AMQShortString consumerTag) |
long |
ProtocolOutputConverterImpl.writeGetOk(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
int queueSize) |
long |
ProtocolOutputConverter.writeGetOk(ServerMessage msg,
InstanceProperties props,
int channelId,
long deliveryTag,
int queueSize) |
Modifier and Type | Method and Description |
---|---|
InstanceProperties |
QueueEntryImpl.getInstanceProperties() |
Modifier and Type | Method and Description |
---|---|
<M extends ServerMessage<? extends StorableMessageMetaData>> |
AbstractQueue.send(M message,
String routingAddress,
InstanceProperties instanceProperties,
ServerTransaction txn,
Action<? super MessageInstance> postEnqueueAction) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.