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 2012/08/17 16:38:12 UTC
svn commit: r1374290 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Author: davsclaus
Date: Fri Aug 17 14:38:12 2012
New Revision: 1374290
URL: http://svn.apache.org/viewvc?rev=1374290&view=rev
Log:
CAMEL-5515: Fixed threads EIP in recent commit.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java?rev=1374290&r1=1374289&r2=1374290&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java Fri Aug 17 14:38:12 2012
@@ -1130,7 +1130,7 @@ public abstract class ProcessorDefinitio
* @return the builder
*/
public ThreadsDefinition threads(int poolSize) {
- ThreadsDefinition answer = threads();
+ ThreadsDefinition answer = new ThreadsDefinition();
answer.setPoolSize(poolSize);
addOutput(answer);
return answer;
@@ -1144,7 +1144,7 @@ public abstract class ProcessorDefinitio
* @return the builder
*/
public ThreadsDefinition threads(int poolSize, int maxPoolSize) {
- ThreadsDefinition answer = threads();
+ ThreadsDefinition answer = new ThreadsDefinition();
answer.setPoolSize(poolSize);
answer.setMaxPoolSize(maxPoolSize);
addOutput(answer);
@@ -1160,7 +1160,7 @@ public abstract class ProcessorDefinitio
* @return the builder
*/
public ThreadsDefinition threads(int poolSize, int maxPoolSize, String threadName) {
- ThreadsDefinition answer = threads();
+ ThreadsDefinition answer = new ThreadsDefinition();
answer.setPoolSize(poolSize);
answer.setMaxPoolSize(maxPoolSize);
answer.setThreadName(threadName);