Hi, You can just save an instance of continuous query somewhere and dispose it when required
var listener = new SomeListener(); var someFilter= new CacheEntryEventFilter(_ignite.GetCluster().GetLocalNode(), Const.CacheName); var query = new ContinuousQuery<string, MyObj>(listener, someFilter); //save the reference in a private field _continuousQuery = cache.QueryContinuous(query); Regardless of a cache value. As I understand correctly you have a mixed platform solution (Java + .NET) This may lead to additional marshalling configuration. I will try the posted solution a bit later and reply -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/