svn commit: r961847 - /camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java

[davsclaus]

Author: davsclaus
Date: Thu Jul  8 17:52:34 2010
New Revision: 961847

URL: http://svn.apache.org/viewvc?rev=961847&view=rev
Log:
CAMEL-2909: OracleAQ does not support JMSType header.

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

Modified: 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java?rev=961847&r1=961846&r2=961847&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
 (original)
+++ 
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsBinding.java
 Thu Jul  8 17:52:34 2010
@@ -171,14 +171,20 @@ public class JmsBinding {
                 map.put("JMSMessageID", jmsMessage.getJMSMessageID());
                 map.put("JMSPriority", jmsMessage.getJMSPriority());
                 map.put("JMSRedelivered", jmsMessage.getJMSRedelivered());
+                map.put("JMSTimestamp", jmsMessage.getJMSTimestamp());
+
                 // to work around OracleAQ not supporting the JMSReplyTo 
header (CAMEL-2909)
                 try {
                     map.put("JMSReplyTo", jmsMessage.getJMSReplyTo());
                 } catch (JMSException e) {
                     LOG.trace("Cannot read JMSReplyTo header. Will ignore this 
exception.", e);
                 }
-                map.put("JMSTimestamp", jmsMessage.getJMSTimestamp());
-                map.put("JMSType", jmsMessage.getJMSType());
+                // to work around OracleAQ not supporting the JMSType header 
(CAMEL-2909)
+                try {
+                    map.put("JMSType", jmsMessage.getJMSType());
+                } catch (JMSException e) {
+                    LOG.trace("Cannot read JMSReplyTo header. Will ignore this 
exception.", e);
+                }
 
                 // this works around a bug in the ActiveMQ property handling
                 map.put("JMSXGroupID", 
jmsMessage.getStringProperty("JMSXGroupID"));