Hi camel-dev,
It looks like children processors of load balancer are not being
wrapped by interceptor strategy. As a result, sendTo processors may
not be debuggable by Debugger or monitored by JMX. Let me know if I
should log a JIRA.
Thanks,
William
Index: camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
===================================================================
--- camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
(revision
706661)
+++ camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java
(working
copy)
@@ -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;
}
-
+