org.apache.qpid.server.protocol.v0_10

Class WindowCreditManager

java.lang.Object

org.apache.qpid.server.flow.AbstractFlowCreditManager

org.apache.qpid.server.protocol.v0_10.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

Constructor Summary

Constructors

Constructor and Description
WindowCreditManager()
WindowCreditManager(long bytesCreditLimit, long messageCreditLimit)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCredit(long count, long bytes)
void	clearCredit()
long	getBytesCredit()
long	getBytesCreditLimit()
long	getMessageCredit()
long	getMessageCreditLimit()
boolean	hasCredit()
void	restoreCredit(long messageCredit, long bytesCredit)
void	setCreditLimits(long bytesCreditLimit, long messageCreditLimit)
boolean	useCreditForMessage(long msgSize)

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

getBytesCreditLimit

public long getBytesCreditLimit()

getMessageCreditLimit

public long getMessageCreditLimit()

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

Specified by:

useCreditForMessage in interface FlowCreditManager

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