Package com.atlassian.bamboo.v2.build.agent

Class ParallelizingMessageListener

java.lang.Object
com.atlassian.bamboo.v2.build.agent.ParallelizingMessageListener
All Implemented Interfaces:
javax.jms.MessageListener
public class ParallelizingMessageListener extends Object implements javax.jms.MessageListener

  • Constructor Details

    • ParallelizingMessageListener

      public ParallelizingMessageListener(javax.jms.MessageListener messageListener, String listenerName)

  • Method Details

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