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 int	MAX_UNREFERENCED_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)
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
int	unReferencedCreditsSize()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_UNREFERENCED_CREDITS_CACHE_SIZE

public static final int MAX_UNREFERENCED_CREDITS_CACHE_SIZE

See Also:

Constant Field Values

Constructor Detail

ClientProducerCreditManagerImpl

public ClientProducerCreditManagerImpl(ClientSessionInternal session,
                                       int windowSize)

Method Detail

setCallback

public 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

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

unReferencedCreditsSize

public int unReferencedCreditsSize()

Specified by:

unReferencedCreditsSize in interface ClientProducerCreditManager