activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1420821 - /activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
Date Wed, 12 Dec 2012 16:48:15 GMT
Author: chirino
Date: Wed Dec 12 16:48:14 2012
New Revision: 1420821

URL: http://svn.apache.org/viewvc?rev=1420821&view=rev
Log:
Make sure the JMSDestination is even on foreign messages.

Modified:
    activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java

Modified: activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java?rev=1420821&r1=1420820&r2=1420821&view=diff
==============================================================================
--- activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
(original)
+++ activemq/trunk/activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
Wed Dec 12 16:48:14 2012
@@ -1756,18 +1756,18 @@ public class ActiveMQSession implements 
 
             // transform to our own message format here
             ActiveMQMessage msg = ActiveMQMessageTransformation.transformMessage(message,
connection);
+           msg.setDestination(destination);
 
             // Set the message id.
             if (msg == message) {
                 msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(),
sequenceNumber));
             } else {
                 msg.setMessageId(new MessageId(producer.getProducerInfo().getProducerId(),
sequenceNumber));
-                message.setJMSMessageID(msg.getMessageId().toString());
+                // Make sure the JMS destination is set on the foreign messages too.
+                message.setJMSDestination(destination);
             }
             //clear the brokerPath in case we are re-sending this message
             msg.setBrokerPath(null);
-            // destination format is provider specific so only set on transformed message
-            msg.setJMSDestination(destination);
 
             msg.setTransactionId(txid);
             if (connection.isCopyMessageOnSend()) {



Mime
View raw message