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

Class ClientProducerCreditsImpl

java.lang.Object

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

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

All Implemented Interfaces:

ClientProducerCredits

public class ClientProducerCreditsImpl
extends AbstractProducerCreditsImpl

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl

address, arriving, blocked, closed, pendingCredits, serverRespondedWithFail, sessionContext, windowSize

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	actualAcquire(int credits)
protected void	afterAcquired(int credits)
void	close()
int	getBalance()
void	receiveCredits(int credits)
void	releaseOutstanding()
void	reset()

Methods inherited from class org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl

acquireCredits, checkCredits, decrementRefCount, getAddress, incrementRefCount, init, isBlocked, receiveFailCredits, requestCredits

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

afterAcquired

protected void afterAcquired(int credits)
                      throws ActiveMQAddressFullException

Overrides:

afterAcquired in class AbstractProducerCreditsImpl

Throws:

ActiveMQAddressFullException

actualAcquire

protected void actualAcquire(int credits)

Specified by:

actualAcquire in class AbstractProducerCreditsImpl

reset

public void reset()

Specified by:

reset in interface ClientProducerCredits

Overrides:

reset in class AbstractProducerCreditsImpl

close

public void close()

Specified by:

close in interface ClientProducerCredits

Overrides:

close in class AbstractProducerCreditsImpl

receiveCredits

public void receiveCredits(int credits)

Specified by:

receiveCredits in interface ClientProducerCredits

Overrides:

receiveCredits in class AbstractProducerCreditsImpl

releaseOutstanding

public void releaseOutstanding()

getBalance

public int getBalance()

Specified by:

getBalance in class AbstractProducerCreditsImpl