@Test
public void receiveInputStream() throws Exception {

  Message<String> event = new Message<String>(0, 1L, 2, 3L, "message");
  byte[] input = mapper.writeValueAsBytes(event);
  underTest.receiveByteArray(input);
  verify(eventHandler).onEvent(event);
}