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()){