518519520521522523524525526527528
} Message<?> m2; int count2 = 0; String result2 = null; while ((m2 = tapSink.receive(1000)) != null) { count2++; result2 = (String) m2.getPayload(); } assertEquals("DRACARYS!", result1);