Re: continuous query - changes from local server only

[dkarachentsev]

Hi,

You may fuse filter for that, for example:

ContinuousQuery<Integer, Integer> qry = new ContinuousQuery<>();

        final Set<ClusterNode> nodes = new
HashSet<>(client.cluster().forDataNodes("cache")
            .forHost(client.cluster().localNode()).nodes());

        qry.setRemoteFilterFactory(new
Factory<CacheEntryEventFilter&lt;Integer, Integer>>() {
            @Override public CacheEntryEventFilter<Integer, Integer>
create() {
                return new CacheEntryEventFilter<Integer, Integer>() {
                    @IgniteInstanceResource
                    private Ignite ignite;

                    @Override public boolean evaluate(
                        CacheEntryEvent<? extends Integer, ? extends
Integer> event) throws CacheEntryListenerException {
                        // Server nodes on current host
                        return nodes.contains(ignite.cluster().localNode());
                    }
                };
            }
        });

Thanks!
-Dmitry



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/