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
 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.


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.