diff --git a/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java b/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java index ca8da342bf..8bd60a65e0 100755 --- a/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java +++ b/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java @@ -115,9 +115,11 @@ public class ActiveMQTextMessage extends ActiveMQMessage implements TextMessage 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; } }