public class ConcurrentMessageListener
extends java.lang.Object
implements org.springframework.jms.listener.SessionAwareMessageListener
Constructor and Description |
---|
ConcurrentMessageListener(int concurrentThreads,
java.lang.Object delegateListener,
java.lang.String destination,
java.lang.ThreadGroup threadGroup,
java.lang.String threadPrefix)
Creates a listener with a given number of process threads.
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ThreadPoolExecutor |
getTaskExecutor() |
void |
onMessage(javax.jms.Message message,
javax.jms.Session session)
Intercept a message to increment a child count of the input CAS.
|
void |
setAnalysisEngineController(AnalysisEngineController controller) |
void |
stop() |
public ConcurrentMessageListener(int concurrentThreads, java.lang.Object delegateListener, java.lang.String destination, java.lang.ThreadGroup threadGroup, java.lang.String threadPrefix) throws java.io.InvalidClassException
concurrentThreads
- - number of threads to use to process CASesdelegateListener
- - JmsInputChannel instance to delegate CAS tojava.io.InvalidClassException
public java.util.concurrent.ThreadPoolExecutor getTaskExecutor()
public void stop()
public void setAnalysisEngineController(AnalysisEngineController controller)
public void onMessage(javax.jms.Message message, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener
javax.jms.JMSException
Copyright © 2012. All Rights Reserved.