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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidactualAcquire(int credits)protected voidafterAcquired(int credits)voidclose()intgetBalance()voidreceiveCredits(int credits)voidreleaseOutstanding()voidreset()-
Methods inherited from class org.apache.activemq.artemis.core.client.impl.AbstractProducerCreditsImpl
acquireCredits, checkCredits, decrementRefCount, getAddress, incrementRefCount, init, isBlocked, receiveFailCredits, requestCredits
-
-
-
-
Constructor Detail
-
ClientProducerCreditsImpl
public ClientProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)
-
-
Method Detail
-
afterAcquired
protected void afterAcquired(int credits) throws ActiveMQAddressFullException- Overrides:
afterAcquiredin classAbstractProducerCreditsImpl- Throws:
ActiveMQAddressFullException
-
actualAcquire
protected void actualAcquire(int credits)
- Specified by:
actualAcquirein classAbstractProducerCreditsImpl
-
reset
public void reset()
- Specified by:
resetin interfaceClientProducerCredits- Overrides:
resetin classAbstractProducerCreditsImpl
-
close
public void close()
- Specified by:
closein interfaceClientProducerCredits- Overrides:
closein classAbstractProducerCreditsImpl
-
receiveCredits
public void receiveCredits(int credits)
- Specified by:
receiveCreditsin interfaceClientProducerCredits- Overrides:
receiveCreditsin classAbstractProducerCreditsImpl
-
releaseOutstanding
public void releaseOutstanding()
-
getBalance
public int getBalance()
- Specified by:
getBalancein classAbstractProducerCreditsImpl
-
-