activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r779587 - /activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
Date Thu, 28 May 2009 12:58:27 GMT
Author: dejanb
Date: Thu May 28 12:58:27 2009
New Revision: 779587

URL: http://svn.apache.org/viewvc?rev=779587&view=rev
Log:
reflecting camel-jms api changes

Modified:
    activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java

Modified: activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java?rev=779587&r1=779586&r2=779587&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
(original)
+++ activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
Thu May 28 12:58:27 2009
@@ -87,7 +87,7 @@
             throw new IllegalArgumentException("Invalid destination setting: " + destination
+ " when expected: " + this.destination);
         }
         try {
-            JmsExchange exchange = new JmsExchange(endpoint.getCamelContext(), ExchangePattern.InOnly,
camelDestination.getBinding(), message);
+            JmsExchange exchange = new JmsExchange(endpoint, ExchangePattern.InOnly, camelDestination.getBinding(),
message);
             producer.process(exchange);
         } catch (JMSException e) {
             throw e;



Mime
View raw message