static AmqpMessageCoder of() {
    return new AmqpMessageCoder();
  }
@Test
  public void encodeDecode() throws Exception {
    Message message = Message.Factory.create();
    message.setBody(new AmqpValue("body"));
    message.setAddress("address");
    message.setSubject("test");
    AmqpMessageCoder coder = AmqpMessageCoder.of();

    Message clone = CoderUtils.clone(coder, message);

    assertEquals("AmqpValue{body}", clone.getBody().toString());
    assertEquals("address", clone.getAddress());
    assertEquals("test", clone.getSubject());
  }