public abstract class AbstractConsumerTarget extends Object implements ConsumerTarget
ConsumerTarget.State
Modifier | Constructor and Description |
---|---|
protected |
AbstractConsumerTarget(ConsumerTarget.State initialState) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
acquisitionRemoved, allocateCredit, consumerAdded, consumerRemoved, flushBatched, getSessionModel, getUnacknowledgedBytes, getUnacknowledgedMessages, queueDeleted, queueEmpty, restoreCredit
protected AbstractConsumerTarget(ConsumerTarget.State initialState)
public boolean processPending()
processPending
in interface ConsumerTarget
public boolean hasPendingWork()
hasPendingWork
in interface ConsumerTarget
protected abstract boolean hasStateChanged()
protected abstract boolean hasClosed()
protected abstract void processStateChanged()
protected abstract void processClosed()
public final boolean isSuspended()
isSuspended
in interface ConsumerTarget
protected abstract boolean isFlowSuspended()
public final ConsumerTarget.State getState()
getState
in interface ConsumerTarget
protected final boolean updateState(ConsumerTarget.State from, ConsumerTarget.State to)
public final void notifyCurrentState()
notifyCurrentState
in interface ConsumerTarget
public final void addStateListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
addStateListener
in interface ConsumerTarget
public void removeStateChangeListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
removeStateChangeListener
in interface ConsumerTarget
public final boolean trySendLock()
trySendLock
in interface ConsumerTarget
public final void getSendLock()
getSendLock
in interface ConsumerTarget
public final void releaseSendLock()
releaseSendLock
in interface ConsumerTarget
public final long send(ConsumerImpl consumer, MessageInstance entry, boolean batch)
send
in interface ConsumerTarget
protected abstract void doSend(ConsumerImpl consumer, MessageInstance entry, boolean batch)
public boolean hasMessagesToSend()
hasMessagesToSend
in interface ConsumerTarget
public void sendNextMessage()
sendNextMessage
in interface ConsumerTarget
public final boolean close()
close
in interface ConsumerTarget
protected abstract void afterCloseInternal()
protected abstract void doCloseInternal()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.