You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/01/30 19:24:30 UTC

svn commit: r501506 - in /incubator/activemq/trunk/activemq-core/src: main/java/org/apache/activemq/ActiveMQSession.java test/java/org/apache/activemq/command/MessageCompressionTest.java

Author: chirino
Date: Tue Jan 30 10:24:29 2007
New Revision: 501506

URL: http://svn.apache.org/viewvc?view=rev&rev=501506
Log:
Port of rev 501500 fix for https://issues.apache.org/activemq/browse/AMQ-1140

Added:
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java
      - copied unchanged from r501500, incubator/activemq/branches/activemq-4.1/activemq-core/src/test/java/org/apache/activemq/command/MessageCompressionTest.java
Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java?view=diff&rev=501506&r1=501505&r2=501506
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java Tue Jan 30 10:24:29 2007
@@ -1536,6 +1536,7 @@
 			if(connection.isCopyMessageOnSend()){
 				msg=(ActiveMQMessage)msg.copy();
 			}
+			msg.setConnection(connection);
 			msg.onSend();
 			msg.setProducerId(msg.getMessageId().getProducerId());
 			if(log.isDebugEnabled()){