public  void beforeMarshall(WireFormat wireFormat) throws IOException 
{
        super.beforeMarshall(wireFormat);
        ByteSequence content = getContent();
        if (content == null && text != null) {
            ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
            OutputStream os = bytesOut;
            ActiveMQConnection connection = getConnection();
            if (connection != null && connection.isUseCompression()) {
                compressed = true;
                os = new DeflaterOutputStream(os);
            }
            DataOutputStream dataOut = new DataOutputStream(os);
            MarshallingSupport.writeUTF8(dataOut, this.text);
            dataOut.close();
            setContent(bytesOut.toByteSequence());
            //see https://issues.apache.org/activemq/browse/AMQ-2103
            this.text=null;
        }
}

 public  void clearBody() throws JMSException 
{
        super.clearBody();
        this.text = null;
}

Clears out the message body. Clearing a message's body does not clear its header values or property entries.

If this message body was read-only, calling this method leaves the message body in the same state as an empty body in a newly created message.

 public Message copy() 
{
        ActiveMQTextMessage copy = new ActiveMQTextMessage();
        copy(copy);
        return copy;
}

 public byte getDataStructureType() 
{
        return DATA_STRUCTURE_TYPE;
}

 public String getJMSXMimeType() 
{
        return "jms/text-message";
}

 public int getSize() 
{
        if (size == 0 && content == null && text != null) {
            size = getMinimumMessageSize();
            if (marshalledProperties != null) {
                size += marshalledProperties.getLength();
            }
            size = text.length() * 2;
        }
        return super.getSize();
}

 public String getText() throws JMSException 
{
        if (text == null && getContent() != null) {
            InputStream is = null;
            try {
                ByteSequence bodyAsBytes = getContent();
                if (bodyAsBytes != null) {
                    is = new ByteArrayInputStream(bodyAsBytes);
                    if (isCompressed()) {
                        is = new InflaterInputStream(is);
                    }
                    DataInputStream dataIn = new DataInputStream(is);
                    text = MarshallingSupport.readUTF8(dataIn);
                    dataIn.close();
                    setContent(null);
                }
            } catch (IOException ioe) {
                throw JMSExceptionSupport.create(ioe);
            } finally {
                if (is != null) {
                    try {
                        is.close();
                    } catch (IOException e) {
                        // ignore
                    }
                }
            }
        }
        return text;
}

 public  void setText(String text) throws MessageNotWriteableException 
{
        checkReadOnlyBody();
        this.text = text;
        setContent(null);
}

 public String toString() 
{
        try {
            String text = getText();
        	if (text != null && text.length()  > 63) {
        		text = text.substring(0, 45) + "..." + text.substring(text.length() - 12);
        		HashMap< String, Object > overrideFields = new HashMap< String, Object >();
        		overrideFields.put("text", text);
        		return super.toString(overrideFields);
        	}
        } catch (JMSException e) {
        }
        return super.toString();
}