svn commit: r573005 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java

[chirino]

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;