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