org.apache.activemq.broker.region.policy

Interface SlowConsumerStrategy

All Known Implementing Classes:

AbortSlowAckConsumerStrategy, AbortSlowConsumerStrategy

public interface SlowConsumerStrategy

Interface for a strategy for dealing with slow consumers

Method Summary

Methods

Modifier and Type	Method and Description
void	addDestination(Destination destination) For Strategies that need to examine assigned destination for slow consumers periodically the destination is assigned here.
void	setBrokerService(Broker broker) Sets the Broker instance which can provide a Scheduler among other things.
void	slowConsumer(ConnectionContext context, Subscription subs) Slow consumer event.

Method Detail

slowConsumer

void slowConsumer(ConnectionContext context,
                Subscription subs)

Slow consumer event.

Parameters:

context - Connection context of the subscription.

subs - The subscription object for the slow consumer.

setBrokerService

void setBrokerService(Broker broker)

Sets the Broker instance which can provide a Scheduler among other things.

Parameters:

broker - The running Broker.

addDestination

void addDestination(Destination destination)

For Strategies that need to examine assigned destination for slow consumers periodically the destination is assigned here. If the strategy doesn't is event driven it can just ignore assigned destination.

Parameters:

destination - A destination to add to a watch list.