Modifier and Type | Method and Description |
---|---|
boolean |
ConsumerTarget.allocateCredit(ServerMessage msg) |
void |
ConsumerTarget.restoreCredit(ServerMessage queueEntry) |
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 |
---|---|
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 | Method and Description |
---|---|
static Filterable |
Filterable.Factory.newInstance(ServerMessage message,
InstanceProperties properties) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageReference<M extends ServerMessage> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractServerMessageImpl<X extends AbstractServerMessageImpl<X,T>,T extends StorableMessageMetaData> |
Modifier and Type | Method and Description |
---|---|
<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 |
---|---|
ServerMessage |
MessageInstance.getMessage() |
Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
MessageSource.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
Modifier and Type | Class and Description |
---|---|
class |
InternalMessage |
Modifier and Type | Method and Description |
---|---|
ServerMessage<InternalMessageMetaData> |
InternalMessageMetaDataType.createMessage(StoredMessage<InternalMessageMetaData> msg) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageConverter<M extends ServerMessage,N extends ServerMessage> |
interface |
MessageConverter<M extends ServerMessage,N extends ServerMessage> |
Modifier and Type | Method and Description |
---|---|
ServerMessage<M> |
MessageMetaDataType.createMessage(StoredMessage<M> msg) |
Modifier and Type | Method and Description |
---|---|
static <M extends ServerMessage,N extends ServerMessage> |
MessageConverterRegistry.getConverter(Class<M> from,
Class<N> to) |
static <M extends ServerMessage,N extends ServerMessage> |
MessageConverterRegistry.getConverter(Class<M> from,
Class<N> to) |
Modifier and Type | Class and Description |
---|---|
class |
MessageTransferMessage |
Modifier and Type | Method and Description |
---|---|
ServerMessage<MessageMetaData_0_10> |
MessageMetaDataType_0_10.createMessage(StoredMessage<MessageMetaData_0_10> msg) |
Modifier and Type | Method and Description |
---|---|
Class<ServerMessage> |
MessageConverter_v0_10.getInputClass() |
Modifier and Type | Method and Description |
---|---|
boolean |
ConsumerTarget_0_10.allocateCredit(ServerMessage message) |
MessageTransferMessage |
MessageConverter_v0_10.convert(ServerMessage serverMsg,
VirtualHostImpl vhost) |
void |
ConsumerTarget_0_10.restoreCredit(ServerMessage message) |
Modifier and Type | Class and Description |
---|---|
class |
AMQMessage
A deliverable message.
|
Modifier and Type | Method and Description |
---|---|
ServerMessage<MessageMetaData> |
MessageMetaDataType_0_8.createMessage(StoredMessage<MessageMetaData> msg) |
Modifier and Type | Method and Description |
---|---|
boolean |
ConsumerTarget_0_8.allocateCredit(ServerMessage msg) |
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) |
void |
ConsumerTarget_0_8.restoreCredit(ServerMessage message) |
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 | Class and Description |
---|---|
class |
MessageConverter_to_1_0<M extends ServerMessage> |
Modifier and Type | Class and Description |
---|---|
class |
Message_1_0 |
Modifier and Type | Method and Description |
---|---|
ServerMessage<MessageMetaData_1_0> |
MessageMetaDataType_1_0.createMessage(StoredMessage<MessageMetaData_1_0> msg) |
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) |
Modifier and Type | Method and Description |
---|---|
ServerMessage |
QueueEntryImpl.getMessage() |
Modifier and Type | Method and Description |
---|---|
QueueEntry |
QueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
org.apache.qpid.server.queue.LastValueQueueList.ConflationQueueEntry |
LastValueQueueList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord)
Updates the list using super.add and also updates
LastValueQueueList._latestValuesMap and discards entries as necessary. |
QueueEntry |
OrderedQueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
SortedQueueEntry |
SortedQueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
protected abstract OrderedQueueEntry |
OrderedQueueEntryList.createQueueEntry(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
protected StandardQueueEntry |
StandardQueueEntryList.createQueueEntry(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
protected org.apache.qpid.server.queue.LastValueQueueList.ConflationQueueEntry |
LastValueQueueList.createQueueEntry(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
protected void |
SortedQueueImpl.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
protected void |
AbstractQueue.doEnqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
void |
BaseQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord record) |
void |
AbstractQueue.enqueue(ServerMessage message,
Action<? super MessageInstance> action,
MessageEnqueueRecord enqueueRecord) |
abstract boolean |
NotificationCheck.notifyIfNecessary(ServerMessage<?> msg,
AMQQueue queue,
QueueNotificationListener listener) |
void |
AMQQueue.recover(ServerMessage<?> message,
MessageEnqueueRecord enqueueRecord) |
void |
AbstractQueue.recover(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
Modifier and Type | Method and Description |
---|---|
org.apache.qpid.server.queue.QueueConsumerImpl |
AbstractQueue.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> optionSet) |
Constructor and Description |
---|
OrderedQueueEntry(OrderedQueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord messageEnqueueRecord) |
QueueEntryImpl(QueueEntryList queueEntryList,
ServerMessage message,
long entryId,
MessageEnqueueRecord enqueueRecord) |
QueueEntryImpl(QueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
SortedQueueEntry(SortedQueueEntryList queueEntryList,
ServerMessage message,
long entryId,
MessageEnqueueRecord messageEnqueueRecord) |
StandardQueueEntry(StandardQueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord messageEnqueueRecord) |
Modifier and Type | Method and Description |
---|---|
AbstractSystemMessageSource.Consumer |
TrustStoreMessageSource.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
Modifier and Type | Method and Description |
---|---|
AbstractSystemMessageSource.Consumer |
AbstractSystemMessageSource.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
AbstractSystemMessageSource.Consumer |
VirtualHostPropertiesNode.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.