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) {
