activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r534168 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java
Date Tue, 01 May 2007 17:43:49 GMT
Author: rajdavies
Date: Tue May  1 10:43:49 2007
New Revision: 534168

URL: http://svn.apache.org/viewvc?view=rev&rev=534168
Log:
added sendBody() helper method

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java?view=diff&rev=534168&r1=534167&r2=534168
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/CamelClient.java Tue May
 1 10:43:49 2007
@@ -84,6 +84,22 @@
     public E send(Endpoint<E> endpoint, Processor processor) {
         return producerCache.send(endpoint, processor);
     }
+   
+    /**
+     * Send the body to an endpoint
+     * @param endpointUri
+     * @param body = the payload 
+     * @return the result
+     */
+    public Object sendBody (String endpointUri,final Object body) {
+        E result =  send(endpointUri, new Processor() {
+            public void process(Exchange exchange) {
+                Message in = exchange.getIn();
+                in.setBody(body);
+            }
+        });
+        return result != null ? result.getOut().getBody() : null;
+    }
 
     public Producer<E> getProducer(Endpoint<E> endpoint) {
         return producerCache.getProducer(endpoint);



Mime
View raw message