@Test
public void testConvertUncompressedBytesMessageToAmqpMessageWithAmqpValueBody() throws Exception {

    byte[] expectedPayload = new byte[] { 8, 16, 24, 32 };
    ActiveMQBytesMessage outbound = createBytesMessage();
    outbound.setShortProperty(JMS_AMQP_ORIGINAL_ENCODING, AMQP_VALUE_BINARY);
    outbound.writeBytes(expectedPayload);
    outbound.storeContent();
    outbound.onSend();
    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 Binary);
    assertEquals(4, ((Binary) ((AmqpValue) amqp.getBody()).getValue()).getLength());
    Binary amqpData = (Binary) ((AmqpValue) amqp.getBody()).getValue();
    Binary inputData = new Binary(expectedPayload);
    assertTrue(inputData.equals(amqpData));
}