public class CreditCreditManager extends AbstractFlowCreditManager implements FlowCreditManager_0_10
FlowCreditManager.FlowCreditManagerListener
Constructor and Description |
---|
CreditCreditManager(long bytesCredit,
long messageCredit,
ProtocolEngine protocolEngine) |
Modifier and Type | Method and Description |
---|---|
void |
addCredit(long messageCredit,
long bytesCredit) |
void |
clearCredit() |
boolean |
hasCredit() |
void |
restoreCredit(long messageCredit,
long bytesCredit) |
void |
stop() |
boolean |
useCreditForMessage(long msgSize) |
addStateListener, notifyIncreaseBytesCredit, removeListener, setSuspended
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addStateListener, removeListener
public CreditCreditManager(long bytesCredit, long messageCredit, ProtocolEngine protocolEngine)
public void restoreCredit(long messageCredit, long bytesCredit)
restoreCredit
in interface FlowCreditManager
public void addCredit(long messageCredit, long bytesCredit)
addCredit
in interface FlowCreditManager_0_10
public void clearCredit()
clearCredit
in interface FlowCreditManager_0_10
public boolean hasCredit()
hasCredit
in interface FlowCreditManager
public boolean useCreditForMessage(long msgSize)
useCreditForMessage
in interface FlowCreditManager
public void stop()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.