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/22 17:49:21 UTC
svn commit: r1073400 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Author: cwiklik
Date: Tue Feb 22 16:49:21 2011
New Revision: 1073400
URL: http://svn.apache.org/viewvc?rev=1073400&view=rev
Log:
UIMA-2038 Modified to use shutdownNow on taskExecutor in destroy()
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java?rev=1073400&r1=1073399&r2=1073400&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java Tue Feb 22 16:49:21 2011
@@ -933,7 +933,7 @@ public class UimaDefaultMessageListenerC
__listenerRef.delegateStop();
if (taskExecutor != null && taskExecutor instanceof ThreadPoolTaskExecutor) {
((ThreadPoolTaskExecutor) taskExecutor).getThreadPoolExecutor().purge();
- ((ThreadPoolTaskExecutor) taskExecutor).getThreadPoolExecutor().shutdown();
+ ((ThreadPoolTaskExecutor) taskExecutor).getThreadPoolExecutor().shutdownNow();
((ThreadPoolTaskExecutor) taskExecutor).getThreadPoolExecutor().awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} else if (concurrentListener != null) {
shutdownTaskExecutor(concurrentListener.getTaskExecutor());