svn commit: r721683 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor: MulticastProcessor.java Splitter.java

[davsclaus]

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 [EMAIL PROTECTED] 
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;
+    }
 }