prj.message().remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
</BUG>
System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
try {
<BUG>prj.ignite().forNodeId(nodeId).message().send(TOPIC.ORDERED, msg);
</BUG>
}
catch (IgniteException e) {
e.printStackTrace();
}

orderedLatch.await();
unorderedLatch.await();
System.out.println(">>> Messaging example finished.");
}
}
private static void startListening(final Ignite ignite, IgniteMessaging imsg) throws IgniteException {
imsg.remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
try {
ignite.message(ignite.cluster().forNodeId(nodeId)).send(TOPIC.ORDERED, msg);
}
catch (IgniteException e) {
e.printStackTrace();
}
