svn commit: r706855 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java

[ningjiang]

Author: ningjiang
Date: Tue Oct 21 21:04:31 2008
New Revision: 706855

URL: http://svn.apache.org/viewvc?rev=706855&view=rev
Log:
CAMEL-1013 removed the casting to SendProcessor with thanks to William

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=706855&r1=706854&r2=706855&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 21:04:31 2008
@@ -125,11 +125,10 @@
     @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
+        for (ProcessorType processorType : getOutputs()) {            
             Processor processor = processorType.createProcessor(routeContext);
             processor = 
processorType.wrapProcessorInInterceptors(routeContext, processor);
-            loadBalancer.addProcessor((SendProcessor)processor);
+            loadBalancer.addProcessor(processor);
         }
 
         return loadBalancer;