  @Test(expected = RuntimeException.class)
  public void testBadJsonInput() {

    byte[] bytePayload = "{\"key: value}".getBytes();

    JsonStringMessageDecoder testDecoder = new JsonStringMessageDecoder();
    testDecoder.decode(bytePayload);
  }