public interface SlowConsumerStrategy
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.
|
void slowConsumer(ConnectionContext context, Subscription subs)
context
- Connection context of the subscription.subs
- The subscription object for the slow consumer.void setBrokerService(Broker broker)
broker
- The running Broker.void addDestination(Destination destination)
destination
- A destination to add to a watch list.Copyright © 2005–2022 FuseSource, Corp.. All rights reserved.