org.apache.qpid.server.consumer

Class AbstractConsumerTarget

java.lang.Object

org.apache.qpid.server.consumer.AbstractConsumerTarget

All Implemented Interfaces:

ConsumerTarget

Direct Known Subclasses:

ConsumerTarget_0_10, ConsumerTarget_0_8

public abstract class AbstractConsumerTarget
extends Object
implements ConsumerTarget

Nested Class Summary

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

ConsumerTarget.State

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConsumerTarget(ConsumerTarget.State initialState)

Method Summary

Modifier and Type	Method and Description
void	addStateListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
protected abstract void	afterCloseInternal()
boolean	close()
protected abstract void	doCloseInternal()
protected abstract void	doSend(ConsumerImpl consumer, MessageInstance entry, boolean batch)
void	getSendLock()
ConsumerTarget.State	getState()
protected abstract boolean	hasClosed()
boolean	hasMessagesToSend()
boolean	hasPendingWork()
protected abstract boolean	hasStateChanged()
protected abstract boolean	isFlowSuspended()
boolean	isSuspended()
void	notifyCurrentState()
protected abstract void	processClosed()
boolean	processPending()
protected abstract void	processStateChanged()
void	releaseSendLock()
void	removeStateChangeListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
long	send(ConsumerImpl consumer, MessageInstance entry, boolean batch)
void	sendNextMessage()
boolean	trySendLock()
protected boolean	updateState(ConsumerTarget.State from, ConsumerTarget.State to)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.server.consumer.ConsumerTarget

acquisitionRemoved, allocateCredit, consumerAdded, consumerRemoved, flushBatched, getSessionModel, getUnacknowledgedBytes, getUnacknowledgedMessages, queueDeleted, queueEmpty, restoreCredit

Constructor Detail

AbstractConsumerTarget

protected AbstractConsumerTarget(ConsumerTarget.State initialState)

Method Detail

processPending

public boolean processPending()

Specified by:

processPending in interface ConsumerTarget

hasPendingWork

public boolean hasPendingWork()

Specified by:

hasPendingWork in interface ConsumerTarget

hasStateChanged

protected abstract boolean hasStateChanged()

hasClosed

protected abstract boolean hasClosed()

processStateChanged

protected abstract void processStateChanged()

processClosed

protected abstract void processClosed()

isSuspended

public final boolean isSuspended()

Specified by:

isSuspended in interface ConsumerTarget

isFlowSuspended

protected abstract boolean isFlowSuspended()

getState

public final ConsumerTarget.State getState()

Specified by:

getState in interface ConsumerTarget

updateState

protected final boolean updateState(ConsumerTarget.State from,
                                    ConsumerTarget.State to)

notifyCurrentState

public final void notifyCurrentState()

Specified by:

notifyCurrentState in interface ConsumerTarget

addStateListener

public final void addStateListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)

Specified by:

addStateListener in interface ConsumerTarget

removeStateChangeListener

public void removeStateChangeListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)

Specified by:

removeStateChangeListener in interface ConsumerTarget

trySendLock

public final boolean trySendLock()

Specified by:

trySendLock in interface ConsumerTarget

getSendLock

public final void getSendLock()

Specified by:

getSendLock in interface ConsumerTarget

releaseSendLock

public final void releaseSendLock()

Specified by:

releaseSendLock in interface ConsumerTarget

send

public final long send(ConsumerImpl consumer,
                       MessageInstance entry,
                       boolean batch)

Specified by:

send in interface ConsumerTarget

doSend

protected abstract void doSend(ConsumerImpl consumer,
                               MessageInstance entry,
                               boolean batch)

hasMessagesToSend

public boolean hasMessagesToSend()

Specified by:

hasMessagesToSend in interface ConsumerTarget

sendNextMessage

public void sendNextMessage()

Specified by:

sendNextMessage in interface ConsumerTarget

close

public final boolean close()

Specified by:

close in interface ConsumerTarget

afterCloseInternal

protected abstract void afterCloseInternal()

doCloseInternal

protected abstract void doCloseInternal()