org.apache.qpid.server.flow
Class CreditCreditManager

java.lang.Object
  extended by org.apache.qpid.server.flow.AbstractFlowCreditManager
      extended by org.apache.qpid.server.flow.CreditCreditManager
All Implemented Interfaces:
FlowCreditManager, FlowCreditManager_0_10

public class CreditCreditManager
extends AbstractFlowCreditManager
implements FlowCreditManager_0_10


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.flow.FlowCreditManager
FlowCreditManager.FlowCreditManagerListener
 
Field Summary
 
Fields inherited from class org.apache.qpid.server.flow.AbstractFlowCreditManager
_suspended
 
Constructor Summary
CreditCreditManager()
           
CreditCreditManager(long bytesCredit, long messageCredit)
           
 
Method Summary
 void addCredit(long messageCredit, long bytesCredit)
           
 void clearCredit()
           
 long getBytesCredit()
           
 long getMessageCredit()
           
 boolean hasCredit()
           
 void restoreCredit(long messageCredit, long bytesCredit)
           
 void setCreditLimits(long bytesCredit, long messageCredit)
           
 void stop()
           
 boolean useCreditForMessage(ServerMessage msg)
           
 
Methods inherited from class org.apache.qpid.server.flow.AbstractFlowCreditManager
addStateListener, notifyIncreaseBytesCredit, removeListener, setSuspended
 
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
addStateListener, removeListener
 

Constructor Detail

CreditCreditManager

public CreditCreditManager()

CreditCreditManager

public CreditCreditManager(long bytesCredit,
                           long messageCredit)
Method Detail

setCreditLimits

public void setCreditLimits(long bytesCredit,
                            long messageCredit)

getMessageCredit

public long getMessageCredit()
Specified by:
getMessageCredit in interface FlowCreditManager

getBytesCredit

public long getBytesCredit()
Specified by:
getBytesCredit in interface FlowCreditManager

restoreCredit

public void restoreCredit(long messageCredit,
                          long bytesCredit)
Specified by:
restoreCredit in interface FlowCreditManager

addCredit

public void addCredit(long messageCredit,
                      long bytesCredit)
Specified by:
addCredit in interface FlowCreditManager_0_10

clearCredit

public void clearCredit()
Specified by:
clearCredit in interface FlowCreditManager_0_10

hasCredit

public boolean hasCredit()
Specified by:
hasCredit in interface FlowCreditManager

useCreditForMessage

public boolean useCreditForMessage(ServerMessage msg)
Specified by:
useCreditForMessage in interface FlowCreditManager

stop

public void stop()


Licensed to the Apache Software Foundation