Interface SlowConsumerStrategy
-
- All Known Implementing Classes:
AbortSlowAckConsumerStrategy
,AbortSlowConsumerStrategy
public interface SlowConsumerStrategy
Interface for a strategy for dealing with slow consumers
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.
-
-