svn commit: r981743 - /camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java

[davsclaus]

Author: davsclaus
Date: Tue Aug  3 05:42:58 2010
New Revision: 981743

URL: http://svn.apache.org/viewvc?rev=981743&view=rev
Log:
Improved stopping seda consumers a bit.

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java?rev=981743&r1=981742&r2=981743&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaConsumer.java
 Tue Aug  3 05:42:58 2010
@@ -204,11 +204,12 @@ public class SedaConsumer extends Servic
     protected void doStop() throws Exception {
         endpoint.onStopped(this);
         // must shutdown executor on stop to avoid overhead of having them 
running
-        
endpoint.getCamelContext().getExecutorServiceStrategy().shutdownNow(executor);
+        
endpoint.getCamelContext().getExecutorServiceStrategy().shutdown(executor);
         executor = null;
 
         if (multicast != null) {
-            ServiceHelper.stopServices(multicast);
+            ServiceHelper.stopService(multicast);
+            multicast = null;
         }
     }