How to stop listen for topic in Ignite?
I'm using https://apacheignite.readme.io/docs/messaging Topic Based
Messaging.
Everything works well,but I cant stop topic listening.
Ignite ignite = Ignition.start("ignite-config.xml");
IgniteMessaging rmtMsg = ignite.message();
rmtMsg.localListen("MyOrderedTopic", (nodeId, msg) -> {
System.out.println("accepted");
return true;
});
rmtMsg.send("MyOrderedTopic", "message");
rmtMsg.stopLocalListen("MyOrderedTopic", (nodeId, msg) -> {
System.out.println("stopped");
return true;
});
rmtMsg.send("MyOrderedTopic", "message");
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Stoppin-listen-for-topics-in-Ignite-tp11604.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
