@Test
public void testConvertCompressedStreamMessageToAmqpMessageWithAmqpValueBody() throws Exception {

    ActiveMQStreamMessage outbound = createStreamMessage(true);
    outbound.writeBoolean(false);
    outbound.writeString("test");
    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 AmqpValue);
    assertTrue(((AmqpValue) amqp.getBody()).getValue() instanceof List);
    @SuppressWarnings("unchecked")
    List<Object> amqpList = (List<Object>) ((AmqpValue) amqp.getBody()).getValue();
    assertEquals(2, amqpList.size());
}