svn commit: r488982 - /incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java

[gnodet]

Author: gnodet
Date: Wed Dec 20 00:57:08 2006
New Revision: 488982

URL: http://svn.apache.org/viewvc?view=rev&rev=488982
Log:
JMS flow does not shutdown its executor

Modified:
    
incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java

Modified: 
incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java?view=diff&rev=488982&r1=488981&r2=488982
==============================================================================
--- 
incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
 (original)
+++ 
incubator/servicemix/trunk/core/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
 Wed Dec 20 00:57:08 2006
@@ -357,6 +357,9 @@
         broker.getContainer().removeListener(endpointListener);
         // Remove component listener
         broker.getContainer().removeListener(componentListener);
+        // Shutdown executor
+        executor.shutdown();
+        // Close connection
         if (this.connection != null) {
             try {
                 this.connection.close();