Hi,
It is not mandatory to provide a filter.
For example, this will get all the events from "myCache"
ContinuousQuery<Integer, BinaryObject> qry = new ContinuousQuery<>();
qry.setLocalListener(new MyEventListener());
myCache.withKeepBinary().query(qry);
@IgniteAsyncCallback
private class MyEventListener implements CacheEntryUpdatedListener<Integer,
BinaryObject> {
@Override
public void onUpdated(Iterable<CacheEntryEvent<? extends Integer, ?
extends BinaryObject>> evts) {
// Do what you want here
}
}
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/