Class ContinuousQueryImpl<K,​V>

  • All Implemented Interfaces:
    org.infinispan.query.api.continuous.ContinuousQuery<K,​V>

    public final class ContinuousQueryImpl<K,​V>
    extends Object
    implements org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
    A container of continuous query listeners for a cache.

    This class is not threadsafe.

    Since:
    8.2
    Author:
    anistor@redhat.com
    • Constructor Detail

      • ContinuousQueryImpl

        public ContinuousQueryImpl​(RemoteCache<K,​V> cache)
    • Method Detail

      • addContinuousQueryListener

        public <C> void addContinuousQueryListener​(String queryString,
                                                   org.infinispan.query.api.continuous.ContinuousQueryListener<K,​C> listener)
        Specified by:
        addContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
      • addContinuousQueryListener

        public <C> void addContinuousQueryListener​(String queryString,
                                                   Map<String,​Object> namedParameters,
                                                   org.infinispan.query.api.continuous.ContinuousQueryListener<K,​C> listener)
        Specified by:
        addContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
      • addContinuousQueryListener

        public <C> void addContinuousQueryListener​(org.infinispan.query.dsl.Query query,
                                                   org.infinispan.query.api.continuous.ContinuousQueryListener<K,​C> listener)
        Registers a continuous query listener that uses a query DSL based filter. The listener will receive notifications when a cache entry joins or leaves the matching set defined by the query.
        Specified by:
        addContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
        Parameters:
        listener - the continuous query listener instance
        query - the query to be used for determining the matching set
      • removeContinuousQueryListener

        public void removeContinuousQueryListener​(org.infinispan.query.api.continuous.ContinuousQueryListener<K,​?> listener)
        Specified by:
        removeContinuousQueryListener in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
      • getListeners

        public List<org.infinispan.query.api.continuous.ContinuousQueryListener<K,​?>> getListeners()
        Specified by:
        getListeners in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>
      • removeAllListeners

        public void removeAllListeners()
        Specified by:
        removeAllListeners in interface org.infinispan.query.api.continuous.ContinuousQuery<K,​V>