public class ConcurrentMessageListener extends Object implements org.springframework.jms.listener.SessionAwareMessageListener
| Constructor and Description |
|---|
ConcurrentMessageListener(int concurrentThreads,
Object delegateListener,
String destination,
ThreadGroup threadGroup,
String threadPrefix)
Creates a listener with a given number of process threads.
|
| Modifier and Type | Method and Description |
|---|---|
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(org.apache.uima.aae.controller.AnalysisEngineController controller) |
void |
stop() |
public ConcurrentMessageListener(int concurrentThreads,
Object delegateListener,
String destination,
ThreadGroup threadGroup,
String threadPrefix)
throws InvalidClassException
concurrentThreads - - number of threads to use to process CASesdelegateListener - - JmsInputChannel instance to delegate CAS toInvalidClassExceptionpublic ThreadPoolExecutor getTaskExecutor()
public void stop()
public void setAnalysisEngineController(org.apache.uima.aae.controller.AnalysisEngineController controller)
public void onMessage(javax.jms.Message message,
javax.jms.Session session)
throws javax.jms.JMSException
onMessage in interface org.springframework.jms.listener.SessionAwareMessageListenerjavax.jms.JMSExceptionCopyright © 2006–2018 The Apache Software Foundation. All rights reserved.