</BUG>
orderedLatch.countDown();
return orderedLatch.getCount() > 0;
});
<BUG>grp.message().localListen(TOPIC.UNORDERED, (nodeId, msg) -> {
</BUG>
unorderedLatch.countDown();
return unorderedLatch.getCount() > 0;
});
}

private static void localListen(
IgniteMessaging imsg,
final CountDownLatch orderedLatch,
final CountDownLatch unorderedLatch
) {
imsg.localListen(TOPIC.ORDERED, (nodeId, msg) -> {
orderedLatch.countDown();
return orderedLatch.getCount() > 0;
});
imsg.localListen(TOPIC.UNORDERED, (nodeId, msg) -> {
unorderedLatch.countDown();
return unorderedLatch.getCount() > 0;
});
