Author: cwiklik
Date: Thu Feb 10 16:03:08 2011
New Revision: 1069444
URL: http://svn.apache.org/viewvc?rev=1069444&view=rev
Log:
UIMA-2038 Added getTaskExecutor()
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java?rev=1069444&r1=1069443&r2=1069444&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java
(original)
+++
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java
Thu Feb 10 16:03:08 2011
@@ -126,19 +126,11 @@ public class ConcurrentMessageListener i
}
}
}
-
+ public ThreadPoolExecutor getTaskExecutor() {
+ return executor;
+ }
public void stop() {
- if (executor != null) {
- executor.shutdownNow();
- blockingExecutor.stop();
- while (!executor.isTerminated()) {
- try {
- executor.awaitTermination(200, TimeUnit.MILLISECONDS);
- } catch (InterruptedException e) {
- break;
- }
- }
- }
+ blockingExecutor.stop();
}
public void setAnalysisEngineController(AnalysisEngineController controller)
{
