Hello experts,
I met an issue on topic based messaging between two Ignite nodes.
I start two nodes one by one.
The first started node send a message, the second node can receive the
message and handle it in the predicate as expected.
<http://apache-ignite-users.70518.x6.nabble.com/file/t2330/WechatIMG46.jpeg>
*But the message sent by the second started node can deliver the first
started node, the first node cannot handle it since there is not a
listener.*
The first node will hit the log.
log.debug("Received message for unknown listener (messages will be kept
until a " +
"listener is registered): " + msg);
<http://apache-ignite-users.70518.x6.nabble.com/file/t2330/WechatIMG47.jpeg>
My usage is similar with the example
https://apacheignite.readme.io/docs/messaging
----------------------------------------------------------------
rmtMsg = ignite.message(ignite.cluster().forRemotes());
rmtMsg.remoteListen(msgTopicChangeNotification, (nodeId, msg) -> {
MessageBody messageBody = (MessageBody) msg;
...
}
----------------------------------------------------------------
I would appreciate you any comment on this.
Thanks,
Ro.
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
