org.apache.qpid.server.flow
Class WindowCreditManager

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

public class WindowCreditManager
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
WindowCreditManager()
           
WindowCreditManager(long bytesCreditLimit, long messageCreditLimit)
           
 
Method Summary
 void addCredit(long count, long bytes)
           
 void clearCredit()
           
 long getBytesCredit()
           
 long getMessageCredit()
           
 boolean hasCredit()
           
 void restoreCredit(long messageCredit, long bytesCredit)
           
 void setCreditLimits(long bytesCreditLimit, long messageCreditLimit)
           
 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

WindowCreditManager

public WindowCreditManager()

WindowCreditManager

public WindowCreditManager(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

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()

addCredit

public void addCredit(long count,
                      long bytes)
Specified by:
addCredit in interface FlowCreditManager_0_10

clearCredit

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


Licensed to the Apache Software Foundation