public class ConsumerTarget_0_10 extends AbstractConsumerTarget implements FlowCreditManager.FlowCreditManagerListener
Modifier and Type | Class and Description |
---|---|
static class |
ConsumerTarget_0_10.AddMessageDispositionListenerAction |
ConsumerTarget.State
Constructor and Description |
---|
ConsumerTarget_0_10(ServerSession session,
String name,
MessageAcceptMode acceptMode,
MessageAcquireMode acquireMode,
MessageFlowMode flowMode,
FlowCreditManager_0_10 creditManager,
Map<String,Object> arguments) |
addStateListener, close, getSendLock, getState, hasMessagesToSend, hasPendingWork, isSuspended, notifyCurrentState, processPending, releaseSendLock, removeStateChangeListener, send, sendNextMessage, trySendLock, updateState
public ConsumerTarget_0_10(ServerSession session, String name, MessageAcceptMode acceptMode, MessageAcquireMode acquireMode, MessageFlowMode flowMode, FlowCreditManager_0_10 creditManager, Map<String,Object> arguments)
public boolean isFlowSuspended()
isFlowSuspended
in class AbstractConsumerTarget
protected void afterCloseInternal()
afterCloseInternal
in class AbstractConsumerTarget
protected void doCloseInternal()
doCloseInternal
in class AbstractConsumerTarget
public void creditStateChanged(boolean hasCredit)
creditStateChanged
in interface FlowCreditManager.FlowCreditManagerListener
public String getName()
public void transportStateChanged()
public void doSend(ConsumerImpl consumer, MessageInstance entry, boolean batch)
doSend
in class AbstractConsumerTarget
public void flushCreditState(boolean strict)
protected void sendToDLQOrDiscard(ConsumerImpl consumer, MessageInstance entry)
protected EventLogger getEventLogger()
public void queueDeleted()
queueDeleted
in interface ConsumerTarget
public boolean allocateCredit(ServerMessage message)
allocateCredit
in interface ConsumerTarget
public void restoreCredit(ServerMessage message)
restoreCredit
in interface ConsumerTarget
public FlowCreditManager_0_10 getCreditManager()
public void stop()
public void addCredit(MessageCreditUnit unit, long value)
public void setFlowMode(MessageFlowMode flowMode)
public boolean isStopped()
public void acquisitionRemoved(MessageInstance entry)
acquisitionRemoved
in interface ConsumerTarget
public void flush()
public ServerSession getSessionModel()
getSessionModel
in interface ConsumerTarget
public boolean isDurable()
public void queueEmpty()
queueEmpty
in interface ConsumerTarget
public void flushBatched()
flushBatched
in interface ConsumerTarget
public void consumerAdded(ConsumerImpl sub)
consumerAdded
in interface ConsumerTarget
public void consumerRemoved(ConsumerImpl sub)
consumerRemoved
in interface ConsumerTarget
public long getUnacknowledgedBytes()
getUnacknowledgedBytes
in interface ConsumerTarget
public long getUnacknowledgedMessages()
getUnacknowledgedMessages
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
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.