Package org.apache.activemq.artemis.core.server.federation

Interface FederatedQueueConsumer

All Superinterfaces:

MessageHandler

All Known Implementing Classes:

FederatedQueueConsumerImpl

public interface FederatedQueueConsumer
extends MessageHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FEDERATION_NAME
static final String	FEDERATION_UPSTREAM_NAME

Method Summary

Modifier and Type	Method	Description
void	close()
int	decrementCount()
ClientSession	getClientSession()
Federation	getFederation()
FederationUpstream	getFederationUpstream()
FederatedConsumerKey	getKey()
static int	getNextDelay(int delay, int delayMultiplier, int delayMax)
int	incrementCount()
void	start()

Methods inherited from interface org.apache.activemq.artemis.api.core.client.MessageHandler

onMessage, onMessageExpired

Field Details

FEDERATION_NAME

static final String FEDERATION_NAME

See Also:

• Constant Field Values

FEDERATION_UPSTREAM_NAME

static final String FEDERATION_UPSTREAM_NAME

See Also:

• Constant Field Values

Method Details

getNextDelay

static int getNextDelay(int delay,
 int delayMultiplier,
 int delayMax)

getFederationUpstream

FederationUpstream getFederationUpstream()

getFederation

Federation getFederation()

getKey

FederatedConsumerKey getKey()

getClientSession

ClientSession getClientSession()

incrementCount

int incrementCount()

decrementCount

int decrementCount()

start

void start()

close

void close()