You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2007/10/16 18:59:49 UTC
svn commit: r585197 -
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java
Author: jstrachan
Date: Tue Oct 16 09:59:30 2007
New Revision: 585197
URL: http://svn.apache.org/viewvc?rev=585197&view=rev
Log:
minor change - moving the thread methods into the Fluent API section
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java?rev=585197&r1=585196&r2=585197&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java Tue Oct 16 09:59:30 2007
@@ -191,6 +191,35 @@
return to(endpoints);
}
+
+ /**
+ * Causes subsequent processors to be called asynchronously
+ *
+ * @param coreSize the number of threads that will be used to process
+ * messages in subsequent processors.
+ * @return a ThreadType builder that can be used to futher configure the
+ * the thread pool.
+ */
+ public ThreadType thread(int coreSize) {
+ ThreadType answer = new ThreadType(coreSize);
+ addOutput(answer);
+ return answer;
+ }
+
+ /**
+ * Causes subsequent processors to be called asynchronously
+ *
+ * @param executor the executor that will be used to process
+ * messages in subsequent processors.
+ * @return a ThreadType builder that can be used to further configure the
+ * the thread pool.
+ */
+ public ProcessorType<Type> thread(ThreadPoolExecutor executor) {
+ ThreadType answer = new ThreadType(executor);
+ addOutput(answer);
+ return this;
+ }
+
/**
* Creates an {@link IdempotentConsumer} to avoid duplicate messages
*/
@@ -1124,31 +1153,4 @@
return processor;
}
- /**
- * Causes subsequent processors to be called asynchronously
- *
- * @param coreSize the number of threads that will be used to process
- * messages in subsequent processors.
- * @return a ThreadType builder that can be used to futher configure the
- * the thread pool.
- */
- public ThreadType thread(int coreSize) {
- ThreadType answer = new ThreadType(coreSize);
- addOutput(answer);
- return answer;
- }
-
- /**
- * Causes subsequent processors to be called asynchronously
- *
- * @param executor the executor that will be used to process
- * messages in subsequent processors.
- * @return a ThreadType builder that can be used to further configure the
- * the thread pool.
- */
- public ProcessorType<Type> thread(ThreadPoolExecutor executor) {
- ThreadType answer = new ThreadType(executor);
- addOutput(answer);
- return this;
- }
}