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

[ningjiang]

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