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

Interface ClientProducerCreditManager

All Known Implementing Classes:

ClientProducerCreditManagerImpl

public interface ClientProducerCreditManager

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()

Method Detail

getCredits

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

returnCredits

void returnCredits(SimpleString address)

receiveCredits

void receiveCredits(SimpleString address,
                    int credits)

receiveFailCredits

void receiveFailCredits(SimpleString address,
                        int credits)

reset

void reset()

close

void close()

creditsMapSize

int creditsMapSize()

unReferencedCreditsSize

int unReferencedCreditsSize()

setCallback

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