org.apache.qpid.server.protocol.v0_10

Class ConsumerTarget_0_10

java.lang.Object

org.apache.qpid.server.consumer.AbstractConsumerTarget

org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10

All Implemented Interfaces:

ConsumerTarget, FlowCreditManager.FlowCreditManagerListener

public class ConsumerTarget_0_10
extends AbstractConsumerTarget
implements FlowCreditManager.FlowCreditManagerListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConsumerTarget_0_10.AddMessageDispositionListenerAction

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

ConsumerTarget.State

Constructor Summary

Constructors

Constructor and Description
ConsumerTarget_0_10(ServerSession session, String name, org.apache.qpid.transport.MessageAcceptMode acceptMode, org.apache.qpid.transport.MessageAcquireMode acquireMode, org.apache.qpid.transport.MessageFlowMode flowMode, FlowCreditManager_0_10 creditManager, Map<String,Object> arguments)

Method Summary

Methods

Modifier and Type	Method and Description
void	acquisitionRemoved(MessageInstance entry)
void	addCredit(org.apache.qpid.transport.MessageCreditUnit unit, long value)
boolean	allocateCredit(ServerMessage message)
boolean	close()
void	consumerAdded(ConsumerImpl sub)
void	consumerRemoved(ConsumerImpl sub)
void	creditStateChanged(boolean hasCredit)
boolean	deleteAcquired(MessageInstance entry)
void	flush()
void	flushBatched()
void	flushCreditState(boolean strict)
Map<String,Object>	getArguments()
ConsumerImpl	getConsumer()
FlowCreditManager_0_10	getCreditManager()
protected EventLogger	getEventLogger()
String	getName()
ServerSession	getSessionModel()
long	getUnacknowledgedBytes()
long	getUnacknowledgedMessages()
boolean	isDurable()
boolean	isStopped()
boolean	isSuspended()
void	queueDeleted()
void	queueEmpty()
void	restoreCredit(ServerMessage message)
long	send(MessageInstance entry, boolean batch)
protected void	sendToDLQOrDiscard(MessageInstance entry)
void	setFlowMode(org.apache.qpid.transport.MessageFlowMode flowMode)
void	stop()

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

getState, getStateListener, setStateListener, updateState

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerTarget_0_10

public ConsumerTarget_0_10(ServerSession session,
                   String name,
                   org.apache.qpid.transport.MessageAcceptMode acceptMode,
                   org.apache.qpid.transport.MessageAcquireMode acquireMode,
                   org.apache.qpid.transport.MessageFlowMode flowMode,
                   FlowCreditManager_0_10 creditManager,
                   Map<String,Object> arguments)

Method Detail

getConsumer

public ConsumerImpl getConsumer()

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface ConsumerTarget

close

public boolean close()

Specified by:

close in interface ConsumerTarget

creditStateChanged

public void creditStateChanged(boolean hasCredit)

Specified by:

creditStateChanged in interface FlowCreditManager.FlowCreditManagerListener

getName

public String getName()

send

public long send(MessageInstance entry,
        boolean batch)

Specified by:

send in interface ConsumerTarget

flushCreditState

public void flushCreditState(boolean strict)

sendToDLQOrDiscard

protected void sendToDLQOrDiscard(MessageInstance entry)

getEventLogger

protected EventLogger getEventLogger()

queueDeleted

public void queueDeleted()

Specified by:

queueDeleted in interface ConsumerTarget

allocateCredit

public boolean allocateCredit(ServerMessage message)

Specified by:

allocateCredit in interface ConsumerTarget

restoreCredit

public void restoreCredit(ServerMessage message)

Specified by:

restoreCredit in interface ConsumerTarget

getCreditManager

public FlowCreditManager_0_10 getCreditManager()

stop

public void stop()

addCredit

public void addCredit(org.apache.qpid.transport.MessageCreditUnit unit,
             long value)

setFlowMode

public void setFlowMode(org.apache.qpid.transport.MessageFlowMode flowMode)

isStopped

public boolean isStopped()

deleteAcquired

public boolean deleteAcquired(MessageInstance entry)

acquisitionRemoved

public void acquisitionRemoved(MessageInstance entry)

Specified by:

acquisitionRemoved in interface ConsumerTarget

flush

public void flush()

getSessionModel

public ServerSession getSessionModel()

Specified by:

getSessionModel in interface ConsumerTarget

isDurable

public boolean isDurable()

getArguments

public Map<String,Object> getArguments()

queueEmpty

public void queueEmpty()

Specified by:

queueEmpty in interface ConsumerTarget

flushBatched

public void flushBatched()

Specified by:

flushBatched in interface ConsumerTarget

consumerAdded

public void consumerAdded(ConsumerImpl sub)

Specified by:

consumerAdded in interface ConsumerTarget

consumerRemoved

public void consumerRemoved(ConsumerImpl sub)

Specified by:

consumerRemoved in interface ConsumerTarget

getUnacknowledgedBytes

public long getUnacknowledgedBytes()

Specified by:

getUnacknowledgedBytes in interface ConsumerTarget

getUnacknowledgedMessages

public long getUnacknowledgedMessages()

Specified by:

getUnacknowledgedMessages in interface ConsumerTarget