static AmqpMessageCoder of() {
    return new AmqpMessageCoder();
  }
@Test
  public void encodeDecodeLargeMessage() throws Exception {
    Message message = Message.Factory.create();
    message.setAddress("address");
    message.setSubject("subject");
    String body = Joiner.on("").join(Collections.nCopies(32 * 1024 * 1024, " "));
    message.setBody(new AmqpValue(body));

    AmqpMessageCoder coder = AmqpMessageCoder.of();

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

    assertEquals(message.getBody().toString(), clone.getBody().toString());
  }