You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2007/10/26 18:10:27 UTC

svn commit: r588695 - /activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java

Author: jstrachan
Date: Fri Oct 26 09:10:27 2007
New Revision: 588695

URL: http://svn.apache.org/viewvc?rev=588695&view=rev
Log:
support InOut exchanges by default if a replyto destination is available on JMS

Modified:
    activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java

Modified: activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java?rev=588695&r1=588694&r2=588695&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java (original)
+++ activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/EndpointMessageListener.java Fri Oct 26 09:10:27 2007
@@ -59,6 +59,9 @@
             }
             Destination replyDestination = getReplyToDestination(message);
             final JmsExchange exchange = createExchange(message, replyDestination);
+            if (replyDestination != null) {
+                exchange.setPattern(ExchangePattern.InOut);
+            }
             if (eagerLoadingOfProperties) {
                 exchange.getIn().getHeaders();
             }