You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2011/02/10 17:03:08 UTC
svn commit: r1069444 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/ConcurrentMessageListener.java
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) {