Class ConsumerWorkService

  • public final class ConsumerWorkService
    extends Object
    • Constructor Detail

      • ConsumerWorkService

        public ConsumerWorkService​(ExecutorService executor,
                                   ThreadFactory threadFactory,
                                   int queueingTimeout,
                                   int shutdownTimeout)
    • Method Detail

      • getShutdownTimeout

        public int getShutdownTimeout()
      • shutdown

        public void shutdown()
        Stop executing all consumer work
      • stopWork

        public void stopWork​(Channel channel)
        Stop executing all consumer work for a particular channel
        channel - to stop consumer work for
      • registerKey

        public void registerKey​(Channel channel)
      • setUnlimited

        public void setUnlimited​(Channel channel,
                                 boolean unlimited)
      • usesPrivateExecutor

        public boolean usesPrivateExecutor()
        true if executor used by this work service is managed by it and wasn't provided by the user