org.hornetq.core.client.impl

Class ClientProducerCreditsImpl

java.lang.Object

org.hornetq.core.client.impl.ClientProducerCreditsImpl

All Implemented Interfaces:

ClientProducerCredits

public class ClientProducerCreditsImpl
extends Object
implements ClientProducerCredits

A ClientProducerCreditsImpl

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
ClientProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)

Method Summary

Methods

Modifier and Type	Method and Description
void	acquireCredits(int credits)
void	close()
int	decrementRefCount()
int	getBalance()
void	incrementRefCount()
void	init()
boolean	isBlocked()
void	receiveCredits(int credits)
void	releaseOutstanding()
void	reset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientProducerCreditsImpl

public ClientProducerCreditsImpl(ClientSessionInternal session,
                         SimpleString address,
                         int windowSize)

Method Detail

init

public void init()

Specified by:

init in interface ClientProducerCredits

acquireCredits

public void acquireCredits(int credits)
                    throws InterruptedException

Specified by:

acquireCredits in interface ClientProducerCredits

Throws:

InterruptedException

isBlocked

public boolean isBlocked()

Specified by:

isBlocked in interface ClientProducerCredits

getBalance

public int getBalance()

receiveCredits

public void receiveCredits(int credits)

Specified by:

receiveCredits in interface ClientProducerCredits

reset

public void reset()

Specified by:

reset in interface ClientProducerCredits

close

public void close()

Specified by:

close in interface ClientProducerCredits

incrementRefCount

public void incrementRefCount()

Specified by:

incrementRefCount in interface ClientProducerCredits

decrementRefCount

public int decrementRefCount()

Specified by:

decrementRefCount in interface ClientProducerCredits

releaseOutstanding

public void releaseOutstanding()

Specified by:

releaseOutstanding in interface ClientProducerCredits