Interface SlowConsumerStrategy

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