camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r721683 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor: MulticastProcessor.java Splitter.java
Date Sat, 29 Nov 2008 15:33:42 GMT
Author: davsclaus
Date: Sat Nov 29 07:33:42 2008
New Revision: 721683

URL: http://svn.apache.org/viewvc?rev=721683&view=rev
Log:
CAMEL-1131: Expose options with getters to help unit test

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Splitter.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java?rev=721683&r1=721682&r2=721683&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
Sat Nov 29 07:33:42 2008
@@ -259,7 +259,7 @@
      * this means the {@link org.apache.camel.processor.aggregate.AggregationStrategy} has
to take care of handling out-of-order arrival of exchanges</li>
      * </ul>
      */
-    protected boolean isStreaming() {
+    public boolean isStreaming() {
         return streaming;
     }
 
@@ -273,4 +273,12 @@
     public AggregationStrategy getAggregationStrategy() {
         return aggregationStrategy;
     }
+
+    public ThreadPoolExecutor getExecutor() {
+        return executor;
+    }
+
+    public boolean isParallelProcessing() {
+        return isParallelProcessing;
+    }
 }

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Splitter.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Splitter.java?rev=721683&r1=721682&r2=721683&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Splitter.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Splitter.java
Sat Nov 29 07:33:42 2008
@@ -52,8 +52,7 @@
         this(expression, destination, aggregationStrategy, false, null, false);
     }
 
-    public Splitter(Expression expression, Processor destination,
-            AggregationStrategy aggregationStrategy,
+    public Splitter(Expression expression, Processor destination, AggregationStrategy aggregationStrategy,
             boolean parallelProcessing, ThreadPoolExecutor threadPoolExecutor, boolean streaming)
{
         super(Collections.singleton(destination), aggregationStrategy, parallelProcessing,
threadPoolExecutor, streaming);
 
@@ -132,4 +131,8 @@
             exchange.getIn().setHeader(SPLIT_SIZE, ((Collection) allPairs).size());
         }
     }
+
+    public Expression getExpression() {
+        return expression;
+    }
 }



Mime
View raw message