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