public class ParallelizingMessageListener extends Object implements javax.jms.MessageListener
Constructor and Description |
---|
ParallelizingMessageListener(javax.jms.MessageListener messageListener,
String listenerName) |
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) |
public ParallelizingMessageListener(javax.jms.MessageListener messageListener, String listenerName)
@PostConstruct public void createExecutors()
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
public void setMaxConcurrentMessages(int maxConcurrentMessages)
public void setMaxConcurrentExpensiveMessages(int maxConcurrentExpensiveMessages)
public void setMaxQueuedExpensiveMessages(int maxQueuedExpensiveMessages)
Copyright © 2022 Atlassian Software Systems Pty Ltd. All rights reserved.