From 9e61ade946a7e348583de6570213224cdf7fe525 Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Wed, 5 Sep 2007 17:18:54 +0000
Subject: [PATCH] Fixing compile issue cause by camel API change

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573005 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/activemq/camel/CamelMessageProducer.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java b/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
index 34ee3345c5..d7a5cd3f63 100644
--- a/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
@@ -25,6 +25,7 @@ import org.apache.activemq.ActiveMQMessageProducerSupport;
 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 @@ public class CamelMessageProducer extends ActiveMQMessageProducerSupport {
             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;