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 2009/06/26 22:02:06 UTC
svn commit: r788842 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Author: cwiklik
Date: Fri Jun 26 20:02:06 2009
New Revision: 788842
URL: http://svn.apache.org/viewvc?rev=788842&view=rev
Log:
UIMA-1109 Added messages to show listener shut down status
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java?rev=788842&r1=788841&r2=788842&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/UimaDefaultMessageListenerContainer.java Fri Jun 26 20:02:06 2009
@@ -744,13 +744,14 @@
}
}
if ( taskExecutor != null ) {
- System.out.println("+++++++++ Listener:"+getDestination()+" Controller ThreadPoolExecutor Stopped ...");
+ System.out.println(">>>>> Thread:"+Thread.currentThread().getId()+ " +++++++++ Listener:"+getDestination()+" Controller ThreadPoolExecutor Stopped ...");
}
// Shutdown the listener
__listenerRef.shutdown();
if ( UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.FINEST) ) {
threadGroup.getParent().list();
}
+ System.out.println(">>>>> Thread:"+Thread.currentThread().getId()+ " ThreadGroupDestroyer waiting for threads to stop. Active thread count:"+threadGroup.activeCount());
// Wait until all threads are accounted for
while (threadGroup.activeCount() > 0) {
try {
@@ -758,13 +759,15 @@
} catch (InterruptedException e) {
}
}
+ System.out.println(">>>>> Thread:"+Thread.currentThread().getId()+ " ThreadGroupDestroyer all threads stopped");
+
try {
synchronized(threadGroup ) {
if ( !threadGroup.isDestroyed() ) {
threadGroup.destroy();
}
}
- System.out.println(">>>>>>>>>>>> Listener:"+getDestinationName()+" Thread Group Destroyed");
+ System.out.println(">>>>> Thread:"+Thread.currentThread().getId()+ " >>>>>>>>>>>> Listener:"+getDestinationName()+" Thread Group Destroyed");
} catch( Exception e) {} // Ignore
}
};