camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r706695 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
Date Tue, 21 Oct 2008 18:05:20 GMT
Author: davsclaus
Date: Tue Oct 21 11:05:19 2008
New Revision: 706695

URL: http://svn.apache.org/viewvc?rev=706695&view=rev
Log:
CAMEL-1013: Applied patch with thanks

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java?rev=706695&r1=706694&r2=706695&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
Tue Oct 21 11:05:19 2008
@@ -121,20 +121,20 @@
         }
         return loadBalancer;
     }
-
-    // when this method will be called
+    
     @Override
     public Processor createProcessor(RouteContext routeContext) throws Exception {
         LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType,
ref);
         for (ProcessorType processorType : getOutputs()) {
             // The outputs should be the SendProcessor
-            SendProcessor processor = (SendProcessor) processorType.createProcessor(routeContext);
-            loadBalancer.addProcessor(processor);
+            Processor processor = processorType.createProcessor(routeContext);
+            processor = processorType.wrapProcessorInInterceptors(routeContext, processor);
+            loadBalancer.addProcessor((SendProcessor)processor);
         }
 
         return loadBalancer;
     }
-
+    
     // Fluent API
     // -------------------------------------------------------------------------
     public LoadBalanceType setLoadBalancer(LoadBalancer loadBalancer) {



Mime
View raw message