Hi Rick,
What's the stack trace you see? Generally, creating/registring a new
continuous query is a proper way of reconnection handling. The issue might
be that the new query is created by a system thread that triggered your
predicate - ignite.events().localListen(new IgnitePredicate()
-
Denis
Dear all,
I have a continuous query on a client node like
IgniteCache cache =
ignite.getOrCreateCache(StoreHelper.getCacheName(BalanceStore.class));
ContinuousQuery qry = new ContinuousQuery<>();
qry.setLocalListener(handler);
qry.setRemoteFilterFactory((Factory>) () -> event
