@Test
public void testBytesMessage() throws Exception {

  createBytesMessage();
  headers.put("key1", "value1");
  headers.put("key2", "value2");
  createHeaders();
  Event event = converter.convert(message).iterator().next();
  assertEquals(headers, event.getHeaders());
  assertArrayEquals(BYTES, event.getBody());
}