org.apache.qpid.server.flow
Class Pre0_10CreditManager

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

public class Pre0_10CreditManager
extends AbstractFlowCreditManager
implements FlowCreditManager


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
Pre0_10CreditManager(long bytesCreditLimit, long messageCreditLimit)
           
 
Method Summary
 long getBytesCredit()
           
 long getMessageCredit()
           
 boolean hasCredit()
           
 void removeAllCredit()
           
 void restoreCredit(long messageCredit, long bytesCredit)
           
 void setCreditLimits(long bytesCreditLimit, long messageCreditLimit)
           
 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

Pre0_10CreditManager

public Pre0_10CreditManager(long bytesCreditLimit,
                            long messageCreditLimit)
Method Detail

setCreditLimits

public void setCreditLimits(long bytesCreditLimit,
                            long messageCreditLimit)

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

removeAllCredit

public void removeAllCredit()

hasCredit

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

useCreditForMessage

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


Licensed to the Apache Software Foundation