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

Class ClientProducerCreditManagerImpl

java.lang.Object

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

All Implemented Interfaces:

ClientProducerCreditManager

public class ClientProducerCreditManagerImpl
extends Object
implements ClientProducerCreditManager

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_ANONYMOUS_CREDITS_CACHE_SIZE

Constructor Summary

Constructors

Constructor	Description
ClientProducerCreditManagerImpl(ClientSessionInternal session, int windowSize)

Method Summary

Modifier and Type	Method	Description
void	close()
int	creditsMapSize()
ClientProducerCredits	getCredits(SimpleString address, boolean anon, SessionContext context)
int	getMaxAnonymousCacheSize()
void	receiveCredits(SimpleString address, int credits)
void	receiveFailCredits(SimpleString address, int credits)
void	reset()
void	returnCredits(SimpleString address)
void	setCallback(ClientProducerFlowCallback callback)	This will determine the flow control as asynchronous, no actual block should happen instead a callback will be sent whenever blockages change

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MAX_ANONYMOUS_CREDITS_CACHE_SIZE

public static final int MAX_ANONYMOUS_CREDITS_CACHE_SIZE

See Also:

• Constant Field Values

Constructor Details

ClientProducerCreditManagerImpl

public ClientProducerCreditManagerImpl(ClientSessionInternal session,
 int windowSize)

Method Details

setCallback

public void setCallback(ClientProducerFlowCallback callback)

Description copied from interface: ClientProducerCreditManager

This will determine the flow control as asynchronous, no actual block should happen instead a callback will be sent whenever blockages change

Specified by:

setCallback in interface ClientProducerCreditManager

getCredits

public ClientProducerCredits getCredits(SimpleString address,
 boolean anon,
 SessionContext context)

Specified by:

getCredits in interface ClientProducerCreditManager

returnCredits

public void returnCredits(SimpleString address)

Specified by:

returnCredits in interface ClientProducerCreditManager

receiveCredits

public void receiveCredits(SimpleString address,
 int credits)

Specified by:

receiveCredits in interface ClientProducerCreditManager

receiveFailCredits

public void receiveFailCredits(SimpleString address,
 int credits)

Specified by:

receiveFailCredits in interface ClientProducerCreditManager

reset

public void reset()

Specified by:

reset in interface ClientProducerCreditManager

close

public void close()

Specified by:

close in interface ClientProducerCreditManager

creditsMapSize

public int creditsMapSize()

Specified by:

creditsMapSize in interface ClientProducerCreditManager

getMaxAnonymousCacheSize

public int getMaxAnonymousCacheSize()

Specified by:

getMaxAnonymousCacheSize in interface ClientProducerCreditManager