svn commit: r1374134 - in /camel/branches/camel-2.10.x: ./ camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java

[ningjiang]

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;
     }