You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/09/05 19:18:54 UTC
svn commit: r573005 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
Author: chirino
Date: Wed Sep 5 10:18:54 2007
New Revision: 573005
URL: http://svn.apache.org/viewvc?rev=573005&view=rev
Log:
Fixing compile issue cause by camel API change
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java?rev=573005&r1=573004&r2=573005&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java Wed Sep 5 10:18:54 2007
@@ -25,6 +25,7 @@
import org.apache.activemq.ActiveMQSession;
import org.apache.activemq.util.JMSExceptionSupport;
import org.apache.camel.Endpoint;
+import org.apache.camel.ExchangePattern;
import org.apache.camel.Producer;
import org.apache.camel.component.jms.JmsExchange;
import org.apache.camel.util.ObjectHelper;
@@ -86,7 +87,7 @@
throw new IllegalArgumentException("Invalid destination setting: " + destination + " when expected: " + this.destination);
}
try {
- JmsExchange exchange = new JmsExchange(endpoint.getContext(), camelDestination.getBinding(), message);
+ JmsExchange exchange = new JmsExchange(endpoint.getContext(), ExchangePattern.InOnly, camelDestination.getBinding(), message);
producer.process(exchange);
} catch (JMSException e) {
throw e;