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 2008/09/03 10:51:29 UTC
svn commit: r691547 - in
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor:
MulticastProcessor.java Splitter.java
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;