Modifier and Type | Method and Description |
---|---|
MessageInstance |
ConsumerMessageInstancePair.getEntry() |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerTarget.acquisitionRemoved(MessageInstance node) |
protected abstract void |
AbstractConsumerTarget.doSend(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
long |
ConsumerTarget.send(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
long |
AbstractConsumerTarget.send(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
Constructor and Description |
---|
ConsumerMessageInstancePair(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
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 |
---|---|
void |
MessageInstance.addStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener) |
boolean |
MessageInstance.removeStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener) |
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
|
Constructor and Description |
---|
MessageInfoImpl(MessageInstance instance,
boolean includeHeaders) |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.acknowledge(ConsumerImpl consumer,
ConsumerTarget_0_10 target,
MessageInstance entry) |
void |
ConsumerTarget_0_10.acquisitionRemoved(MessageInstance entry) |
void |
ConsumerTarget_0_10.doSend(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
protected void |
ConsumerTarget_0_10.sendToDLQOrDiscard(ConsumerImpl consumer,
MessageInstance entry) |
Constructor and Description |
---|
MessageAcceptCompletionListener(ConsumerTarget_0_10 sub,
ConsumerImpl consumer,
ServerSession session,
MessageInstance entry,
boolean restoreCredit) |
Modifier and Type | Method and Description |
---|---|
MessageInstance |
UnacknowledgedMessageMap.get(long deliveryTag) |
MessageInstance |
UnacknowledgedMessageMapImpl.get(long key) |
MessageInstance |
UnacknowledgedMessageMap.remove(long deliveryTag) |
MessageInstance |
UnacknowledgedMessageMapImpl.remove(long deliveryTag) |
Modifier and Type | Method and Description |
---|---|
Collection<MessageInstance> |
UnacknowledgedMessageMap.acknowledge(long deliveryTag,
boolean multiple) |
Collection<MessageInstance> |
UnacknowledgedMessageMapImpl.acknowledge(long deliveryTag,
boolean multiple) |
Collection<MessageInstance> |
UnacknowledgedMessageMap.cancelAllMessages() |
Collection<MessageInstance> |
UnacknowledgedMessageMapImpl.cancelAllMessages() |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerTarget_0_8.acquisitionRemoved(MessageInstance node) |
void |
UnacknowledgedMessageMap.add(long deliveryTag,
MessageInstance message) |
void |
UnacknowledgedMessageMapImpl.add(long deliveryTag,
MessageInstance message) |
protected void |
ConsumerTarget_0_8.addUnacknowledgedMessage(MessageInstance entry) |
void |
AMQChannel.addUnacknowledgedMessage(MessageInstance entry,
long deliveryTag,
ConsumerImpl consumer)
Add a message to the channel-based list of unacknowledged messages
|
boolean |
UnacknowledgedMessageMap.Visitor.callback(long deliveryTag,
MessageInstance message) |
boolean |
ExtractResendAndRequeue.callback(long deliveryTag,
MessageInstance message) |
void |
ConsumerTarget_0_8.NoAckConsumer.doSend(ConsumerImpl consumer,
MessageInstance entry,
boolean batch)
This method can be called by each of the publisher threads.
|
void |
RecordDeliveryMethod.recordMessageDelivery(ConsumerImpl sub,
MessageInstance entry,
long deliveryTag) |
protected void |
ConsumerTarget_0_8.recordMessageDelivery(ConsumerImpl consumer,
MessageInstance entry,
long deliveryTag) |
Modifier and Type | Method and Description |
---|---|
void |
UnacknowledgedMessageMap.collect(long key,
boolean multiple,
Map<Long,MessageInstance> msgs) |
void |
UnacknowledgedMessageMapImpl.collect(long deliveryTag,
boolean multiple,
Map<Long,MessageInstance> msgs) |
void |
UnacknowledgedMessageMapImpl.remove(Map<Long,MessageInstance> msgs) |
Constructor and Description |
---|
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap,
Map<Long,MessageInstance> msgToRequeue,
Map<Long,MessageInstance> msgToResend) |
ExtractResendAndRequeue(UnacknowledgedMessageMap unacknowledgedMessageMap,
Map<Long,MessageInstance> msgToRequeue,
Map<Long,MessageInstance> msgToResend) |
Modifier and Type | Method and Description |
---|---|
void |
SendingLink_1_0.addUnsettled(Binary tag,
UnsettledAction unsettledAction,
MessageInstance queueEntry) |
Modifier and Type | Interface and Description |
---|---|
interface |
QueueEntry |
Modifier and Type | Class and Description |
---|---|
class |
OrderedQueueEntry |
class |
QueueEntryImpl |
class |
SortedQueueEntry
An implementation of QueueEntryImpl to be used in SortedQueueEntryList.
|
class |
StandardQueueEntry |
Modifier and Type | Method and Description |
---|---|
void |
QueueEntryImpl.addStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener) |
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) |
boolean |
QueueEntryImpl.removeStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener) |
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 | Method and Description |
---|---|
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) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.