Class ClientProducerCreditManagerImpl
java.lang.Object
org.apache.activemq.artemis.core.client.impl.ClientProducerCreditManagerImpl
- All Implemented Interfaces:
ClientProducerCreditManager
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionClientProducerCreditManagerImpl(ClientSessionInternal session, int windowSize) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intgetCredits(SimpleString address, boolean anon, SessionContext context) intvoidreceiveCredits(SimpleString address, int credits) voidreceiveFailCredits(SimpleString address, int credits) voidreset()voidreturnCredits(SimpleString address) voidsetCallback(ClientProducerFlowCallback callback) This will determine the flow control as asynchronous, no actual block should happen instead a callback will be sent whenever blockages change
-
Field Details
-
MAX_ANONYMOUS_CREDITS_CACHE_SIZE
public static final int MAX_ANONYMOUS_CREDITS_CACHE_SIZE- See Also:
-
-
Constructor Details
-
ClientProducerCreditManagerImpl
-
-
Method Details
-
setCallback
Description copied from interface:ClientProducerCreditManagerThis will determine the flow control as asynchronous, no actual block should happen instead a callback will be sent whenever blockages change- Specified by:
setCallbackin interfaceClientProducerCreditManager
-
getCredits
- Specified by:
getCreditsin interfaceClientProducerCreditManager
-
returnCredits
- Specified by:
returnCreditsin interfaceClientProducerCreditManager
-
receiveCredits
- Specified by:
receiveCreditsin interfaceClientProducerCreditManager
-
receiveFailCredits
- Specified by:
receiveFailCreditsin interfaceClientProducerCreditManager
-
reset
public void reset()- Specified by:
resetin interfaceClientProducerCreditManager
-
close
public void close()- Specified by:
closein interfaceClientProducerCreditManager
-
creditsMapSize
public int creditsMapSize()- Specified by:
creditsMapSizein interfaceClientProducerCreditManager
-
getMaxAnonymousCacheSize
public int getMaxAnonymousCacheSize()- Specified by:
getMaxAnonymousCacheSizein interfaceClientProducerCreditManager
-