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 2010/04/30 11:27:43 UTC
svn commit: r939601 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
Author: davsclaus
Date: Fri Apr 30 09:27:43 2010
New Revision: 939601
URL: http://svn.apache.org/viewvc?rev=939601&view=rev
Log:
CAMEL-2682: Splitter now returns original exchange as outbound by default.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java?rev=939601&r1=939600&r2=939601&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java Fri Apr 30 09:27:43 2010
@@ -101,7 +101,7 @@ public class MulticastProcessor extends
private final CamelContext camelContext;
private Collection<Processor> processors;
- private AggregationStrategy aggregationStrategy;
+ private final AggregationStrategy aggregationStrategy;
private final boolean parallelProcessing;
private final boolean streaming;
private final boolean stopOnException;
@@ -408,10 +408,6 @@ public class MulticastProcessor extends
return aggregationStrategy;
}
- public void setAggregationStrategy(AggregationStrategy aggregationStrategy) {
- this.aggregationStrategy = aggregationStrategy;
- }
-
public boolean isParallelProcessing() {
return parallelProcessing;
}