@Test
public void testConvertCompressedTextMessageCreatesDataSectionBody() throws Exception {

    String contentString = "myTextMessageContent";
    ActiveMQTextMessage outbound = createTextMessage(contentString, true);
    outbound.setShortProperty(JMS_AMQP_ORIGINAL_ENCODING, AMQP_DATA);
    outbound.onSend();
    outbound.storeContent();
    JMSMappingOutboundTransformer transformer = new JMSMappingOutboundTransformer();
    EncodedMessage encoded = transformer.transform(outbound);
    assertNotNull(encoded);
    Message amqp = encoded.decode();
    assertNotNull(amqp.getBody());
    assertTrue(amqp.getBody() instanceof Data);
    assertTrue(((Data) amqp.getBody()).getValue() instanceof Binary);
    Binary data = ((Data) amqp.getBody()).getValue();
    String contents = new String(data.getArray(), data.getArrayOffset(), data.getLength(), StandardCharsets.UTF_8);
    assertEquals(contentString, contents);
}