org.apache.qpid.server.flow
Class AbstractFlowCreditManager

java.lang.Object
  extended by org.apache.qpid.server.flow.AbstractFlowCreditManager
All Implemented Interfaces:
FlowCreditManager
Direct Known Subclasses:
BytesOnlyCreditManager, CreditCreditManager, LimitlessCreditManager, MessageAndBytesCreditManager, MessageOnlyCreditManager, Pre0_10CreditManager, WindowCreditManager

public abstract class AbstractFlowCreditManager
extends Object
implements FlowCreditManager


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.flow.FlowCreditManager
FlowCreditManager.FlowCreditManagerListener
 
Field Summary
protected  AtomicBoolean _suspended
           
 
Constructor Summary
AbstractFlowCreditManager()
           
 
Method Summary
 void addStateListener(FlowCreditManager.FlowCreditManagerListener listener)
           
protected  void notifyIncreaseBytesCredit()
           
 boolean removeListener(FlowCreditManager.FlowCreditManagerListener listener)
           
protected  void setSuspended(boolean suspended)
           
 
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.flow.FlowCreditManager
getBytesCredit, getMessageCredit, hasCredit, restoreCredit, useCreditForMessage
 

Field Detail

_suspended

protected final AtomicBoolean _suspended
Constructor Detail

AbstractFlowCreditManager

public AbstractFlowCreditManager()
Method Detail

addStateListener

public final void addStateListener(FlowCreditManager.FlowCreditManagerListener listener)
Specified by:
addStateListener in interface FlowCreditManager

removeListener

public final boolean removeListener(FlowCreditManager.FlowCreditManagerListener listener)
Specified by:
removeListener in interface FlowCreditManager

setSuspended

protected final void setSuspended(boolean suspended)

notifyIncreaseBytesCredit

protected final void notifyIncreaseBytesCredit()


Licensed to the Apache Software Foundation