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 Summary
Constructors Constructor Description ParallelizingMessageListener(javax.jms.MessageListener messageListener, String listenerName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
createExecutors()
void
onMessage(javax.jms.Message message)
void
setMaxConcurrentExpensiveMessages(int maxConcurrentExpensiveMessages)
void
setMaxConcurrentMessages(int maxConcurrentMessages)
void
setMaxQueuedExpensiveMessages(int maxQueuedExpensiveMessages)
-
-
-
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 interfacejavax.jms.MessageListener
-
setMaxConcurrentMessages
public void setMaxConcurrentMessages(int maxConcurrentMessages)
-
setMaxConcurrentExpensiveMessages
public void setMaxConcurrentExpensiveMessages(int maxConcurrentExpensiveMessages)
-
setMaxQueuedExpensiveMessages
public void setMaxQueuedExpensiveMessages(int maxQueuedExpensiveMessages)
-
-