org.apache.qpid.server.protocol.v0_8

Class ConsumerTarget_0_8.NoAckConsumer

java.lang.Object

org.apache.qpid.server.consumer.AbstractConsumerTarget

org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8

org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8.NoAckConsumer

All Implemented Interfaces:

ConsumerTarget, FlowCreditManager.FlowCreditManagerListener

Direct Known Subclasses:

ConsumerTarget_0_8.GetNoAckConsumer

Enclosing class:

ConsumerTarget_0_8

public static class ConsumerTarget_0_8.NoAckConsumer
extends ConsumerTarget_0_8

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8

ConsumerTarget_0_8.GetNoAckConsumer, ConsumerTarget_0_8.NoAckConsumer

Nested classes/interfaces inherited from interface org.apache.qpid.server.consumer.ConsumerTarget

ConsumerTarget.State

Constructor Summary

Constructors

Constructor and Description
NoAckConsumer(AMQChannel channel, AMQShortString consumerTag, FieldTable filters, FlowCreditManager creditManager, ClientDeliveryMethod deliveryMethod, RecordDeliveryMethod recordMethod)

Method Summary

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.

Methods inherited from class org.apache.qpid.server.protocol.v0_8.ConsumerTarget_0_8

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

Methods inherited from class org.apache.qpid.server.consumer.AbstractConsumerTarget

addStateListener, close, getSendLock, getState, hasMessagesToSend, hasPendingWork, isSuspended, notifyCurrentState, processPending, releaseSendLock, removeStateChangeListener, send, sendNextMessage, trySendLock, updateState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

NoAckConsumer

public NoAckConsumer(AMQChannel channel,
                     AMQShortString consumerTag,
                     FieldTable filters,
                     FlowCreditManager creditManager,
                     ClientDeliveryMethod deliveryMethod,
                     RecordDeliveryMethod recordMethod)

Method Detail

doSend

public void doSend(ConsumerImpl consumer,
                   MessageInstance entry,
                   boolean batch)

This method can be called by each of the publisher threads. As a result all changes to the channel object must be thread safe.

Specified by:

doSend in class AbstractConsumerTarget

Parameters:

consumer -

entry - The message to send

batch -