public static class ConsumerTarget_0_8.NoAckConsumer extends ConsumerTarget_0_8
ConsumerTarget_0_8.GetNoAckConsumer, ConsumerTarget_0_8.NoAckConsumer
ConsumerTarget.State
Constructor and Description |
---|
NoAckConsumer(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
Modifier and Type | Method and Description |
---|---|
void |
doSend(ConsumerImpl consumer,
MessageInstance entry,
boolean batch)
This method can be called by each of the publisher threads.
|
acquisitionRemoved, addUnacknowledgedMessage, afterCloseInternal, allocateCredit, confirmAutoClose, consumerAdded, consumerRemoved, createAckTarget, createAckTarget, createBrowserTarget, createGetNoAckTarget, createNoAckTarget, createNoAckTarget, creditStateChanged, doCloseInternal, flushBatched, getChannel, getConsumers, getConsumerTag, getCreditManager, getSessionModel, getUnacknowledgedBytes, getUnacknowledgedMessages, hasClosed, hasStateChanged, isAutoClose, isFlowSuspended, processClosed, processStateChanged, queueDeleted, queueEmpty, recordMessageDelivery, restoreCredit, sendToClient, toString
addStateListener, close, getSendLock, getState, hasMessagesToSend, hasPendingWork, isSuspended, notifyCurrentState, processPending, releaseSendLock, removeStateChangeListener, send, sendNextMessage, trySendLock, updateState
public NoAckConsumer(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)
public void doSend(ConsumerImpl consumer, MessageInstance entry, boolean batch)
doSend
in class AbstractConsumerTarget
consumer
- entry
- The message to sendbatch
- Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.