camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r638809 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java
Date Wed, 19 Mar 2008 12:10:28 GMT
Author: jstrachan
Date: Wed Mar 19 05:10:26 2008
New Revision: 638809

URL: http://svn.apache.org/viewvc?rev=638809&view=rev
Log:
fixed a failing test case due to mandatory flag

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java?rev=638809&r1=638808&r2=638809&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/MulticastType.java
Wed Mar 19 05:10:26 2008
@@ -23,6 +23,7 @@
 import javax.xml.bind.annotation.XmlAccessorType;
 import javax.xml.bind.annotation.XmlRootElement;
 import javax.xml.bind.annotation.XmlTransient;
+import javax.xml.bind.annotation.XmlAttribute;
 
 import org.apache.camel.Processor;
 import org.apache.camel.impl.RouteContext;
@@ -36,7 +37,8 @@
 @XmlRootElement(name = "multicast")
 @XmlAccessorType(XmlAccessType.FIELD)
 public class MulticastType extends OutputType<ProcessorType> {
-    private boolean parallelProcessing;
+    @XmlAttribute(required = false)
+    private Boolean parallelProcessing;
     @XmlTransient
     private AggregationStrategy aggregationStrategy;
     @XmlTransient
@@ -56,7 +58,7 @@
         if (aggregationStrategy == null) {
             aggregationStrategy = new UseLatestAggregationStrategy();
         }
-        return new MulticastProcessor(list, aggregationStrategy, parallelProcessing, threadPoolExecutor);
+        return new MulticastProcessor(list, aggregationStrategy, isParallelProcessing(),
threadPoolExecutor);
     }
 
     public AggregationStrategy getAggregationStrategy() {
@@ -68,7 +70,7 @@
     }
 
     public boolean isParallelProcessing() {
-        return parallelProcessing;
+        return parallelProcessing != null ? parallelProcessing : false;
     }
 
     public void setParallelProcessing(boolean parallelProcessing) {



Mime
View raw message