@Test
public void testTextMessage() throws Exception {

  createTextMessage();
  headers.put("key1", "value1");
  headers.put("key2", "value2");
  createHeaders();
  Event event = converter.convert(message).iterator().next();
  assertEquals(headers, event.getHeaders());
  assertEquals(TEXT, new String(event.getBody(), Charsets.UTF_8));
}