Hello Andre,
As mentioned in the javadoc [1], you have to call QueryCursor#close()
method in order to stop receiving updates.
// Create new continuous query.
ContinuousQuery<Long, Person> qry = new ContinuousQuery<>();
// Execute query and get cursor that iterates through initial data.
QueryCursor<Cache.Entry<Long, Person>> cur = cache.query(qry);
...
// Stop receiving updates
cur.close();
[1]
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/cache/query/ContinuousQuery.html
[2]
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/cache/query/QueryCursor.html
Thanks!
2018-03-25 20:47 GMT+03:00 au.fp2018 <[email protected]>:
> Hello All,
>
> What is the correct way to cancel a Continuous Query, and make sure all the
> resources are used by the query are freed?
>
> I looked in the documentation and the examples, I didn't see any explicit
> reference to cancelling a running continuous query.
>
> Thanks,
> Andre
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
