### Question:
SinkApp { @StreamListener(Sink.INPUT) public void handle(final Person person) { System.out.printf("[%s]Received: %s%n", Thread.currentThread().getName(), person); }  static void main(final String[] args); @StreamListener(Sink.INPUT) void handle(final Person person);  }### Answer:
@Test public void testHandle() { final Message<String> message = new GenericMessage<>("{\"name\":\"hoge\"}"); sink.input().send(message); outputCapture.expect(containsString("Received: hoge")); }