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 2008/03/04 19:23:32 UTC

svn commit: r633576 - in /activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms: JmsBinding.java JmsProducer.java

Author: jstrachan
Date: Tue Mar  4 10:23:21 2008
New Revision: 633576

URL: http://svn.apache.org/viewvc?rev=633576&view=rev
Log:
made the camel-jms module backwards compatible with older versions so older ActiveMQ releases work nicely without change on newer Camel distros

Modified:
    activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
    activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java

Modified: activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java?rev=633576&r1=633575&r2=633576&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java (original)
+++ activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java Tue Mar  4 10:23:21 2008
@@ -106,6 +106,17 @@
      * @return a newly created JMS Message instance containing the
      * @throws JMSException if the message could not be created
      */
+    public Message makeJmsMessage(Exchange exchange, Session session) throws JMSException {
+        return makeJmsMessage(exchange, exchange.getIn(), session);
+    }
+
+    /**
+     * Creates a JMS message from the Camel exchange and message
+     *
+     * @param session the JMS session used to create the message
+     * @return a newly created JMS Message instance containing the
+     * @throws JMSException if the message could not be created
+     */
     public Message makeJmsMessage(Exchange exchange, org.apache.camel.Message camelMessage, Session session) throws JMSException {
         Message answer = null;
         if (camelMessage instanceof JmsMessage) {
@@ -119,6 +130,13 @@
         return answer;
     }
 
+    /**
+     * Appends the JMS headers from the Camel {@link JmsMessage}
+     */
+    public void appendJmsProperties(Message jmsMessage, Exchange exchange) throws JMSException {
+        appendJmsProperties(jmsMessage, exchange, exchange.getIn());
+    }
+    
     /**
      * Appends the JMS headers from the Camel {@link JmsMessage}
      */

Modified: activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java?rev=633576&r1=633575&r2=633576&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java (original)
+++ activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java Tue Mar  4 10:23:21 2008
@@ -123,6 +123,16 @@
         }
     }
 
+    /**
+     * Preserved for backwards compatibility.
+     * 
+     * @deprecated
+     * @see #getInOnlyTemplate()
+     */
+    public JmsOperations getTemplate() {
+        return getInOnlyTemplate();
+    }
+
     public JmsOperations getInOnlyTemplate() {
         if (inOnlyTemplate == null) {
             inOnlyTemplate = endpoint.createInOnlyTemplate();