svn commit: r743258 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java

[rajdavies]

Author: rajdavies
Date: Wed Feb 11 07:34:26 2009
New Revision: 743258

URL: http://svn.apache.org/viewvc?rev=743258&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-2103

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java?rev=743258&r1=743257&r2=743258&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
 Wed Feb 11 07:34:26 2009
@@ -115,9 +115,11 @@
                 os = new DeflaterOutputStream(os);
             }
             DataOutputStream dataOut = new DataOutputStream(os);
-            MarshallingSupport.writeUTF8(dataOut, text);
+            MarshallingSupport.writeUTF8(dataOut, this.text);
             dataOut.close();
             setContent(bytesOut.toByteSequence());
+            //see https://issues.apache.org/activemq/browse/AMQ-2103
+            this.text=null;
         }
     }