You should provide the same instance of listener to stop method:
listener = (nodeId, msg) -> { ... }
rmtMsg.localListen("MyOrderedTopic", listener)
...
rmtMsg.stopLocalListen("MyOrderedTopic", listener)-Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Stoppin-listen-for-topics-in-Ignite-tp11604p11631.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
