You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2008/10/21 20:05:20 UTC
svn commit: r706695 -
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
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) {