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:38:35 UTC
svn commit: r1374135 - in /camel/branches/camel-2.9.x: ./
camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Author: ningjiang
Date: Fri Aug 17 04:38:35 2012
New Revision: 1374135
URL: http://svn.apache.org/viewvc?rev=1374135&view=rev
Log:
Merged revisions 1374134 via svnmerge from
https://svn.apache.org/repos/asf/camel/branches/camel-2.10.x
................
r1374134 | ningjiang | 2012-08-17 12:31:17 +0800 (Fri, 17 Aug 2012) | 9 lines
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.9.x/ (props changed)
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Merged /camel/trunk:r1374133
Merged /camel/branches/camel-2.10.x:r1374134
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java?rev=1374135&r1=1374134&r2=1374135&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java Fri Aug 17 04:38:35 2012
@@ -1128,6 +1128,7 @@ public abstract class ProcessorDefinitio
public ThreadsDefinition threads(int poolSize) {
ThreadsDefinition answer = threads();
answer.setPoolSize(poolSize);
+ addOutput(answer);
return answer;
}
@@ -1142,6 +1143,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;
}