svn commit: r725606 - in /activemq/camel/branches/camel-1.x: camel-core/src/main/java/org/apache/camel/model/ camel-core/src/test/java/org/apache/camel/processor/ components/camel-spring/src/test/java/org/apache/camel/spring/processor/ components/camel...

[ni...@apache.org]

Author: ningjiang
Date: Wed Dec 10 23:30:58 2008
New Revision: 725606

URL: http://svn.apache.org/viewvc?rev=725606&view=rev
Log:
Merged revisions 725569,725572 via svnmerge from 
https://svn.apache.org/repos/asf/activemq/camel/trunk

........
  r725569 | ningjiang | 2008-12-11 12:10:08 +0800 (Thu, 11 Dec 2008) | 1 line
  
  CAMEL-1181 added the DSL support and tests
........
  r725572 | ningjiang | 2008-12-11 12:36:13 +0800 (Thu, 11 Dec 2008) | 1 line
  
  CAMEL-1181 added the snippet tags for wiki page
........

Added:
    activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/SetExchangePatternTest.java
      - copied unchanged from r725572, activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/SetExchangePatternTest.java
    activemq/camel/branches/camel-1.x/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringSetExchangePatternTest.java
      - copied unchanged from r725572, activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringSetExchangePatternTest.java
    activemq/camel/branches/camel-1.x/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/setExchangePattern.xml
      - copied unchanged from r725572, activemq/camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/setExchangePattern.xml
Removed:
    activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/ExchangePatternTest.java
    activemq/camel/branches/camel-1.x/components/camel-spring/src/test/java/org/apache/camel/spring/processor/SpringExchangePatternTest.java
    activemq/camel/branches/camel-1.x/components/camel-spring/src/test/resources/org/apache/camel/spring/processor/exchangePattern.xml
Modified:
    activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java

Modified: activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java
URL: http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java?rev=725606&r1=725605&r2=725606&view=diff
==============================================================================
--- activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java (original)
+++ activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/model/ProcessorType.java Wed Dec 10 23:30:58 2008
@@ -127,7 +127,8 @@
     public Type to(String uri) {
         addOutput(new ToType(uri));
         return (Type) this;
-    }
+    }   
+    
 
     /**
      * Sends the exchange to the given endpoint
@@ -136,6 +137,31 @@
         addOutput(new ToType(endpoint));
         return (Type) this;
     }
+    
+    /**
+     * Sends the exchange with certain exchange pattern to the given endpoint
+     *
+     * @param uri  the endpoint to send to
+     * @return the builder
+     */
+    public Type to(String uri, ExchangePattern ep) {
+        addOutput(new SetExchangePatternType(ep));
+        addOutput(new ToType(uri));        
+        return (Type) this;
+    }   
+    
+
+    /**
+     * Sends the exchange with certain exchange pattern to the given endpoint
+     *
+     * @param endpoint  the endpoint to send to
+     * @return the builder
+     */
+    public Type to(Endpoint endpoint, ExchangePattern ep) {
+        addOutput(new SetExchangePatternType(ep));
+        addOutput(new ToType(endpoint));
+        return (Type) this;
+    }
 
     /**
      * Sends the exchange to a list of endpoints
@@ -166,6 +192,8 @@
         }
         return (Type) this;
     }
+    
+    
 
     /**
      * Multicasts messages to all its child outputs; so that each processor and
@@ -1597,6 +1625,50 @@
     public Type inOut() {
         return setExchangePattern(ExchangePattern.InOut);
     }
+    
+    /**
+     * <a href="http://activemq.apache.org/camel/exchange-pattern.html">ExchangePattern:</a>
+     * set the exchange's ExchangePattern {@link ExchangePattern} to be InOnly
+     *
+     * @param uri The endpoint uri which is used for sending the exchange
+     * @return the builder
+     */
+    public Type inOnly(String uri) {
+        return to(uri, ExchangePattern.InOnly);
+    }
+    
+    /**
+     * <a href="http://activemq.apache.org/camel/exchange-pattern.html">ExchangePattern:</a>
+     * set the exchange's ExchangePattern {@link ExchangePattern} to be InOut
+     *
+     * @param uri The endpoint uri which is used for sending the exchange
+     * @return the builder
+     */
+    public Type inOut(String uri) {
+        return to(uri, ExchangePattern.InOut);
+    }
+    
+    /**
+     * <a href="http://activemq.apache.org/camel/exchange-pattern.html">ExchangePattern:</a>
+     * set the exchange's ExchangePattern {@link ExchangePattern} to be InOnly
+     *
+     * @param uri The endpoint which is used for sending the exchange
+     * @return the builder
+     */
+    public Type inOnly(Endpoint endpoint) {
+        return to(endpoint, ExchangePattern.InOnly);
+    }
+    
+    /**
+     * <a href="http://activemq.apache.org/camel/exchange-pattern.html">ExchangePattern:</a>
+     * set the exchange's ExchangePattern {@link ExchangePattern} to be InOut
+     *
+     * @param uri The endpoint which is used for sending the exchange
+     * @return the builder
+     */
+    public Type inOut(Endpoint endpoint) {
+        return to(endpoint, ExchangePattern.InOut);
+    }
 
     // Properties
     // -------------------------------------------------------------------------