org.apache.qpid.server.flow
Class MessageAndBytesCreditManager

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

public class MessageAndBytesCreditManager
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
MessageAndBytesCreditManager(long messageCredit, long bytesCredit)
           
 
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
 
Methods inherited from interface org.apache.qpid.server.flow.FlowCreditManager
addStateListener, removeListener
 

Constructor Detail

MessageAndBytesCreditManager

public MessageAndBytesCreditManager(long messageCredit,
                                    long bytesCredit)
Method Detail

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

setBytesCredit

public void setBytesCredit(long bytesCredit)


Licensed to the Apache Software Foundation