public abstract class ConsumerTarget_0_8 extends AbstractConsumerTarget implements FlowCreditManager.FlowCreditManagerListener
Ties together the protocol session of a subscriber, the consumer tag that was given out by the broker and the channel id.
Modifier and Type | Class and Description |
---|---|
static class |
ConsumerTarget_0_8.GetNoAckConsumer
NoAck Subscription for use with BasicGet method.
|
static class |
ConsumerTarget_0_8.NoAckConsumer |
ConsumerTarget.State
Constructor and Description |
---|
ConsumerTarget_0_8(AMQChannel channel,
AMQShortString consumerTag,
FieldTable arguments,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod) |
addStateListener, close, doSend, getSendLock, getState, hasMessagesToSend, hasPendingWork, isSuspended, notifyCurrentState, processPending, releaseSendLock, removeStateChangeListener, send, sendNextMessage, trySendLock, updateState
public ConsumerTarget_0_8(AMQChannel channel, AMQShortString consumerTag, FieldTable arguments, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)
public static ConsumerTarget_0_8 createBrowserTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager)
public static ConsumerTarget_0_8 createGetNoAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)
public List<ConsumerImpl> getConsumers()
public static ConsumerTarget_0_8 createNoAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager)
public static ConsumerTarget_0_8 createNoAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod) throws QpidException
QpidException
public static ConsumerTarget_0_8 createAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager)
public static ConsumerTarget_0_8 createAckTarget(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)
public void consumerRemoved(ConsumerImpl sub)
consumerRemoved
in interface ConsumerTarget
public void consumerAdded(ConsumerImpl sub)
consumerAdded
in interface ConsumerTarget
public AMQSessionModel getSessionModel()
getSessionModel
in interface ConsumerTarget
public boolean isFlowSuspended()
isFlowSuspended
in class AbstractConsumerTarget
public void queueDeleted()
queueDeleted
in interface ConsumerTarget
public boolean isAutoClose()
public FlowCreditManager getCreditManager()
protected void afterCloseInternal()
afterCloseInternal
in class AbstractConsumerTarget
protected void doCloseInternal()
doCloseInternal
in class AbstractConsumerTarget
public boolean allocateCredit(ServerMessage msg)
allocateCredit
in interface ConsumerTarget
public AMQChannel getChannel()
public AMQShortString getConsumerTag()
public void restoreCredit(ServerMessage message)
restoreCredit
in interface ConsumerTarget
public void creditStateChanged(boolean hasCredit)
creditStateChanged
in interface FlowCreditManager.FlowCreditManagerListener
protected long sendToClient(ConsumerImpl consumer, ServerMessage message, InstanceProperties props, long deliveryTag)
protected void recordMessageDelivery(ConsumerImpl consumer, MessageInstance entry, long deliveryTag)
public void confirmAutoClose()
public void queueEmpty()
queueEmpty
in interface ConsumerTarget
protected void processClosed()
processClosed
in class AbstractConsumerTarget
protected void processStateChanged()
processStateChanged
in class AbstractConsumerTarget
protected boolean hasStateChanged()
hasStateChanged
in class AbstractConsumerTarget
protected boolean hasClosed()
hasClosed
in class AbstractConsumerTarget
public void flushBatched()
flushBatched
in interface ConsumerTarget
protected void addUnacknowledgedMessage(MessageInstance entry)
public void acquisitionRemoved(MessageInstance node)
acquisitionRemoved
in interface ConsumerTarget
public long getUnacknowledgedBytes()
getUnacknowledgedBytes
in interface ConsumerTarget
public long getUnacknowledgedMessages()
getUnacknowledgedMessages
in interface ConsumerTarget
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.