svn commit: r836219 - /camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java

[da...@apache.org]

Author: davsclaus
Date: Sat Nov 14 17:21:27 2009
New Revision: 836219

URL: http://svn.apache.org/viewvc?rev=836219&view=rev
Log:
CAMEL-2170: Ensured using UnitOfWork for EIPs that emit new Exchanges on new routes which didnt have that beforehand. RecipientList should not be in UoW as it send to another endpoint

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java?rev=836219&r1=836218&r2=836219&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RecipientList.java Sat Nov 14 17:21:27 2009
@@ -81,9 +81,7 @@
             Object recipient = iter.next();
             Endpoint endpoint = resolveEndpoint(exchange, recipient);
             Producer producer = getProducerCache(exchange).getProducer(endpoint);
-            // wrap in unit of work
-            Processor target = new UnitOfWorkProcessor(producer);
-            processors.add(target);
+            processors.add(producer);
         }
         MulticastProcessor mp = new MulticastProcessor(processors, new UseLatestAggregationStrategy());
         mp.process(exchange);