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 Summary

Constructors

Constructor and Description
ParallelizingMessageListener(javax.jms.MessageListener messageListener, String listenerName)

Method Summary

Modifier and Type	Method and Description
void	createExecutors()
void	onMessage(javax.jms.Message message)
void	setMaxConcurrentExpensiveMessages(int maxConcurrentExpensiveMessages)
void	setMaxConcurrentMessages(int maxConcurrentMessages)
void	setMaxQueuedExpensiveMessages(int maxQueuedExpensiveMessages)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)