org.apache.qpid.server.flow
Class BytesOnlyCreditManager

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

public class BytesOnlyCreditManager
extends AbstractFlowCreditManager


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
BytesOnlyCreditManager(long initialCredit)
           
 
Method Summary
 long getBytesCredit()
           
 long getMessageCredit()
           
 boolean hasCredit()
           
 void removeAllCredit()
           
 void restoreCredit(long messageCredit, long bytesCredit)
           
 void setBytesCredit(long bytesCredit)
           
 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
 

Constructor Detail

BytesOnlyCreditManager

public BytesOnlyCreditManager(long initialCredit)
Method Detail

getMessageCredit

public long getMessageCredit()

getBytesCredit

public long getBytesCredit()

restoreCredit

public void restoreCredit(long messageCredit,
                          long bytesCredit)

removeAllCredit

public void removeAllCredit()

hasCredit

public boolean hasCredit()

useCreditForMessage

public boolean useCreditForMessage(ServerMessage msg)

setBytesCredit

public void setBytesCredit(long bytesCredit)


Licensed to the Apache Software Foundation