Package org.apache.activemq.artemis.core.client.impl

Class AbstractProducerCreditsImpl

java.lang.Object

org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl

All Implemented Interfaces:

ClientProducerCredits

Direct Known Subclasses:

AsynchronousProducerCreditsImpl, ClientProducerCreditsImpl

public abstract class AbstractProducerCreditsImpl
extends Object
implements ClientProducerCredits

Field Summary

Fields

Modifier and Type	Field	Description
protected SimpleString	address
protected int	arriving
protected boolean	blocked
protected boolean	closed
protected int	pendingCredits
protected boolean	serverRespondedWithFail
protected SessionContext	sessionContext
protected int	windowSize

Constructor Summary

Constructors

Constructor	Description
AbstractProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)

Method Summary

Modifier and Type	Method	Description
void	acquireCredits(int credits)
protected abstract void	actualAcquire(int credits)
protected void	afterAcquired(int credits)
protected void	checkCredits(int credits)
void	close()
int	decrementRefCount()
SimpleString	getAddress()
abstract int	getBalance()
void	incrementRefCount()
void	init(SessionContext sessionContext)
boolean	isBlocked()
void	receiveCredits(int credits)
void	receiveFailCredits(int credits)
protected void	requestCredits(int credits)
void	reset()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.client.impl.ClientProducerCredits

releaseOutstanding

Field Detail

pendingCredits

protected int pendingCredits

windowSize

protected final int windowSize

closed

protected volatile boolean closed

blocked

protected boolean blocked

address

protected final SimpleString address

arriving

protected int arriving

serverRespondedWithFail

protected boolean serverRespondedWithFail

sessionContext

protected SessionContext sessionContext

Constructor Detail

AbstractProducerCreditsImpl

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

Method Detail

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface ClientProducerCredits

init

public void init(SessionContext sessionContext)

Specified by:

init in interface ClientProducerCredits

acquireCredits

public void acquireCredits(int credits)
                    throws ActiveMQException

Specified by:

acquireCredits in interface ClientProducerCredits

Throws:

ActiveMQException

afterAcquired

protected void afterAcquired(int credits)
                      throws ActiveMQAddressFullException

Throws:

ActiveMQAddressFullException

actualAcquire

protected abstract void actualAcquire(int credits)

isBlocked

public boolean isBlocked()

Specified by:

isBlocked in interface ClientProducerCredits

receiveFailCredits

public void receiveFailCredits(int credits)

Specified by:

receiveFailCredits in interface ClientProducerCredits

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

getBalance

public abstract int getBalance()

checkCredits

protected void checkCredits(int credits)

requestCredits

protected void requestCredits(int credits)