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