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 SimpleStringaddressprotected intarrivingprotected booleanblockedprotected booleanclosedprotected intpendingCreditsprotected booleanserverRespondedWithFailprotected SessionContextsessionContextprotected intwindowSize
-
Constructor Summary
Constructors Constructor Description AbstractProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidacquireCredits(int credits)protected abstract voidactualAcquire(int credits)protected voidafterAcquired(int credits)protected voidcheckCredits(int credits)voidclose()intdecrementRefCount()SimpleStringgetAddress()abstract intgetBalance()voidincrementRefCount()voidinit(SessionContext sessionContext)booleanisBlocked()voidreceiveCredits(int credits)voidreceiveFailCredits(int credits)protected voidrequestCredits(int credits)voidreset()-
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:
getAddressin interfaceClientProducerCredits
-
init
public void init(SessionContext sessionContext)
- Specified by:
initin interfaceClientProducerCredits
-
acquireCredits
public void acquireCredits(int credits) throws ActiveMQException- Specified by:
acquireCreditsin interfaceClientProducerCredits- 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:
isBlockedin interfaceClientProducerCredits
-
receiveFailCredits
public void receiveFailCredits(int credits)
- Specified by:
receiveFailCreditsin interfaceClientProducerCredits
-
receiveCredits
public void receiveCredits(int credits)
- Specified by:
receiveCreditsin interfaceClientProducerCredits
-
reset
public void reset()
- Specified by:
resetin interfaceClientProducerCredits
-
close
public void close()
- Specified by:
closein interfaceClientProducerCredits
-
incrementRefCount
public void incrementRefCount()
- Specified by:
incrementRefCountin interfaceClientProducerCredits
-
decrementRefCount
public int decrementRefCount()
- Specified by:
decrementRefCountin interfaceClientProducerCredits
-
getBalance
public abstract int getBalance()
-
checkCredits
protected void checkCredits(int credits)
-
requestCredits
protected void requestCredits(int credits)
-
-