activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject 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
Date Tue, 30 Jan 2007 18:24:30 GMT
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()){



Mime
View raw message