Class AsynchronousProducerCreditsImpl
- java.lang.Object
-
- org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl
-
- org.apache.activemq.artemis.core.client.impl.AsynchronousProducerCreditsImpl
-
- All Implemented Interfaces:
ClientProducerCredits
public class AsynchronousProducerCreditsImpl 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 AsynchronousProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize, ClientProducerFlowCallback callback)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidactualAcquire(int credits)intgetBalance()voidreceiveCredits(int credits)voidreceiveFailCredits(int credits)voidreleaseOutstanding()-
Methods inherited from class org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl
acquireCredits, afterAcquired, checkCredits, close, decrementRefCount, getAddress, incrementRefCount, init, isBlocked, requestCredits, reset
-
-
-
-
Constructor Detail
-
AsynchronousProducerCreditsImpl
public AsynchronousProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize, ClientProducerFlowCallback callback)
-
-
Method Detail
-
actualAcquire
protected void actualAcquire(int credits)
- Specified by:
actualAcquirein classAbstractProducerCreditsImpl
-
getBalance
public int getBalance()
- Specified by:
getBalancein classAbstractProducerCreditsImpl
-
receiveCredits
public void receiveCredits(int credits)
- Specified by:
receiveCreditsin interfaceClientProducerCredits- Overrides:
receiveCreditsin classAbstractProducerCreditsImpl
-
receiveFailCredits
public void receiveFailCredits(int credits)
- Specified by:
receiveFailCreditsin interfaceClientProducerCredits- Overrides:
receiveFailCreditsin classAbstractProducerCreditsImpl
-
releaseOutstanding
public void releaseOutstanding()
-
-