Class ParallelizingMessageListener

  • All Implemented Interfaces:
    javax.jms.MessageListener

    public class ParallelizingMessageListener
    extends Object
    implements javax.jms.MessageListener
    • Constructor Detail

      • ParallelizingMessageListener

        public ParallelizingMessageListener​(javax.jms.MessageListener messageListener,
                                            String listenerName)
    • Method Detail

      • createExecutors

        @PostConstruct
        public void createExecutors()
      • onMessage

        public void onMessage​(javax.jms.Message message)
        Specified by:
        onMessage in interface javax.jms.MessageListener
      • setMaxConcurrentMessages

        public void setMaxConcurrentMessages​(int maxConcurrentMessages)
      • setMaxConcurrentExpensiveMessages

        public void setMaxConcurrentExpensiveMessages​(int maxConcurrentExpensiveMessages)
      • setMaxQueuedExpensiveMessages

        public void setMaxQueuedExpensiveMessages​(int maxQueuedExpensiveMessages)