svn commit: r1137704 - /camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java

[davsclaus]

Author: davsclaus
Date: Mon Jun 20 17:02:52 2011
New Revision: 1137704

URL: http://svn.apache.org/viewvc?rev=1137704&view=rev
Log:
Fixed issue with fine grained error handling on MulticastProcessor not starting 
the created ErrorHandlers

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java?rev=1137704&r1=1137703&r2=1137704&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
 Mon Jun 20 17:02:52 2011
@@ -855,6 +855,8 @@ public class MulticastProcessor extends 
             // instead of using ProcessorDefinition.wrapInErrorHandler)
             try {
                 processor = builder.createErrorHandler(routeContext, 
processor);
+                // must start the error handler
+                ServiceHelper.startServices(processor);
             } catch (Exception e) {
                 throw ObjectHelper.wrapRuntimeCamelException(e);
             }
@@ -931,7 +933,7 @@ public class MulticastProcessor extends 
     }
 
     protected void doStop() throws Exception {
-        ServiceHelper.stopServices(processors);
+        ServiceHelper.stopServices(processors, errorHandlers);
         errorHandlers.clear();
     }