@Test
public void testObjectMessage() throws Exception {

  createObjectMessage();
  headers.put("key1", "value1");
  headers.put("key2", "value2");
  createHeaders();
  Event event = converter.convert(message).iterator().next();
  assertEquals(headers, event.getHeaders());
  ByteArrayOutputStream bos = new ByteArrayOutputStream();
  ObjectOutput out = new ObjectOutputStream(bos);
  out.writeObject(TEXT);
  assertArrayEquals(bos.toByteArray(), event.getBody());
}