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

[davsclaus]

Author: davsclaus
Date: Wed Sep  3 01:51:28 2008
New Revision: 691547

URL: http://svn.apache.org/viewvc?rev=691547&view=rev
Log:
polished code

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=691547&r1=691546&r2=691547&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
 Wed Sep  3 01:51:28 2008
@@ -16,8 +16,6 @@
  */
 package org.apache.camel.processor;
 
-
-
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
@@ -63,8 +61,6 @@
         public Exchange getExchange() {
             return exchange;
         }
-
-
     }
 
     private Collection<Processor> processors;
@@ -89,12 +85,11 @@
         if (isParallelProcessing) {
             if (executor != null) {
                 this.executor = executor;
-            } else { // setup default Executor
+            } else { 
+                // setup default Executor
                 this.executor = new ThreadPoolExecutor(processors.size(), 
processors.size(), 0, TimeUnit.MILLISECONDS, new 
ArrayBlockingQueue<Runnable>(processors.size()));
             }
-
         }
-
     }
 
     /**
@@ -202,8 +197,7 @@
         // No updates needed
     }
 
-    protected List<ProcessorExchangePair> createProcessorExchangePairs(
-        Exchange exchange) {
+    protected List<ProcessorExchangePair> 
createProcessorExchangePairs(Exchange exchange) {
         List<ProcessorExchangePair> result = new 
ArrayList<ProcessorExchangePair>(processors.size());
         Processor[] processorsArray = processors.toArray(new 
Processor[processors.size()]);
         for (int i = 0; i < processorsArray.length; i++) {

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=691547&r1=691546&r2=691547&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
 Wed Sep  3 01:51:28 2008
@@ -31,6 +31,7 @@
 import org.apache.camel.util.CollectionHelper;
 
 import static org.apache.camel.util.ObjectHelper.notNull;
+
 /**
  * Implements a dynamic <a
  * href="http://activemq.apache.org/camel/splitter.html";>Splitter</a> pattern
@@ -65,8 +66,7 @@
     }
 
     @Override
-    protected List<ProcessorExchangePair> createProcessorExchangePairs(
-        Exchange exchange) {
+    protected List<ProcessorExchangePair> 
createProcessorExchangePairs(Exchange exchange) {
         Object value = expression.evaluate(exchange);
         Integer collectionSize = CollectionHelper.size(value);
         List<ProcessorExchangePair> result;