You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2012/08/17 06:31:17 UTC
svn commit: r1374134 - in /camel/branches/camel-2.10.x: ./
camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Author: ningjiang
Date: Fri Aug 17 04:31:17 2012
New Revision: 1374134
URL: http://svn.apache.org/viewvc?rev=1374134&view=rev
Log:
Merged revisions 1374133 via svnmerge from
https://svn.apache.org/repos/asf/camel/trunk
........
r1374133 | ningjiang | 2012-08-17 12:20:40 +0800 (Fri, 17 Aug 2012) | 1 line
CAMEL-5515 Fixed the issue of thread Java DSL
........
Modified:
camel/branches/camel-2.10.x/ (props changed)
camel/branches/camel-2.10.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Merged /camel/trunk:r1374133
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.10.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java?rev=1374134&r1=1374133&r2=1374134&view=diff
==============================================================================
--- camel/branches/camel-2.10.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java (original)
+++ camel/branches/camel-2.10.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java Fri Aug 17 04:31:17 2012
@@ -1132,6 +1132,7 @@ public abstract class ProcessorDefinitio
public ThreadsDefinition threads(int poolSize) {
ThreadsDefinition answer = threads();
answer.setPoolSize(poolSize);
+ addOutput(answer);
return answer;
}
@@ -1146,6 +1147,24 @@ public abstract class ProcessorDefinitio
ThreadsDefinition answer = threads();
answer.setPoolSize(poolSize);
answer.setMaxPoolSize(maxPoolSize);
+ addOutput(answer);
+ return answer;
+ }
+
+ /**
+ * Continues processing the {@link org.apache.camel.Exchange} using asynchronous routing engine.
+ *
+ * @param poolSize the core pool size
+ * @param maxPoolSize the maximum pool size
+ * @param threadName the thread pool name
+ * @return the builder
+ */
+ public ThreadsDefinition threads(int poolSize, int maxPoolSize, String threadName) {
+ ThreadsDefinition answer = threads();
+ answer.setPoolSize(poolSize);
+ answer.setMaxPoolSize(maxPoolSize);
+ answer.setThreadName(threadName);
+ addOutput(answer);
return answer;
}