Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
ConsumerMessageInstancePair.getConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerTarget.consumerAdded(ConsumerImpl sub) |
void |
ConsumerTarget.consumerRemoved(ConsumerImpl sub) |
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 | Class and Description |
---|---|
static class |
MessageInstance.ConsumerAcquiredState<C extends ConsumerImpl> |
static class |
MessageInstance.LockedAcquiredState<C extends ConsumerImpl> |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageSourceConsumer<X extends MessageSourceConsumer<X>> |
Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
MessageSource.addConsumer(ConsumerTarget target,
FilterManager filters,
Class<? extends ServerMessage> messageClass,
String consumerName,
EnumSet<ConsumerImpl.Option> options) |
ConsumerImpl |
MessageInstance.getAcquiringConsumer() |
ConsumerImpl |
MessageInstance.getDeliveredConsumer() |
Modifier and Type | Method and Description |
---|---|
Collection<? extends ConsumerImpl> |
MessageSource.getConsumers() |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageInstance.acquire(ConsumerImpl sub) |
boolean |
MessageInstance.isAcquiredBy(ConsumerImpl consumer) |
boolean |
MessageInstance.isRejectedBy(ConsumerImpl consumer) |
boolean |
MessageInstance.lockAcquisition(ConsumerImpl consumer) |
void |
MessageInstance.release(ConsumerImpl release) |
boolean |
MessageInstance.removeAcquisitionFromConsumer(ConsumerImpl consumer) |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.acknowledge(ConsumerImpl consumer,
ConsumerTarget_0_10 target,
MessageInstance entry) |
void |
ConsumerTarget_0_10.consumerAdded(ConsumerImpl sub) |
void |
ConsumerTarget_0_10.consumerRemoved(ConsumerImpl sub) |
void |
ConsumerTarget_0_10.doSend(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
void |
ServerSession.register(ConsumerImpl consumerImpl) |
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 |
---|---|
List<ConsumerImpl> |
ConsumerTarget_0_8.getConsumers() |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.addUnacknowledgedMessage(MessageInstance entry,
long deliveryTag,
ConsumerImpl consumer)
Add a message to the channel-based list of unacknowledged messages
|
void |
ConsumerTarget_0_8.consumerAdded(ConsumerImpl sub) |
void |
ConsumerTarget_0_8.consumerRemoved(ConsumerImpl sub) |
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.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) |
protected long |
ConsumerTarget_0_8.sendToClient(ConsumerImpl consumer,
ServerMessage message,
InstanceProperties props,
long deliveryTag) |
Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
SendingLink_1_0.getConsumer() |
Modifier and Type | Interface and Description |
---|---|
interface |
QueueConsumer<X extends QueueConsumer<X>> |
Modifier and Type | Method and Description |
---|---|
ConsumerImpl |
QueueEntryImpl.getAcquiringConsumer() |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueEntryImpl.acquire(ConsumerImpl sub) |
boolean |
QueueEntryImpl.isAcquiredBy(ConsumerImpl consumer) |
boolean |
QueueEntryImpl.isRejectedBy(ConsumerImpl consumer) |
boolean |
QueueEntryImpl.lockAcquisition(ConsumerImpl consumer) |
void |
QueueEntryImpl.release(ConsumerImpl consumer) |
boolean |
QueueEntryImpl.removeAcquisitionFromConsumer(ConsumerImpl consumer) |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractSystemMessageSource.Consumer |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.