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.