public static final class ConsumerTarget_0_8.GetNoAckConsumer extends ConsumerTarget_0_8.NoAckConsumer
ConsumerTarget_0_8.GetNoAckConsumer, ConsumerTarget_0_8.NoAckConsumer
ConsumerTarget.State
Constructor and Description |
---|
GetNoAckConsumer(AMQChannel channel,
AMQShortString consumerTag,
FieldTable filters,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
doSend
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 GetNoAckConsumer(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.