Interface ContinuousQuery<K,V>

All Known Implementing Classes:
ContinuousQueryImpl

public interface ContinuousQuery<K,V>
A container of continuous query listeners for a cache.

Implementations are not expected to be threadsafe.

Since:
8.2
Author:
anistor@redhat.com
  • Method Details

    • addContinuousQueryListener

      <C> void addContinuousQueryListener(String queryString, ContinuousQueryListener<K,C> listener)
      Add a listener for a continuous query.
      Parameters:
      queryString - the query
      listener - the listener
    • addContinuousQueryListener

      <C> void addContinuousQueryListener(String queryString, Map<String,Object> namedParameters, ContinuousQueryListener<K,C> listener)
      Add a listener for a continuous query.
      Parameters:
      queryString - the query
      namedParameters - the query parameters
      listener - the listener
    • addContinuousQueryListener

      <C> void addContinuousQueryListener(Query<?> query, ContinuousQueryListener<K,C> listener)
      Add a listener for a continuous query.
      Parameters:
      query - the query object
      listener - the listener
    • removeContinuousQueryListener

      void removeContinuousQueryListener(ContinuousQueryListener<K,?> listener)
      Remove a continuous query listener.
      Parameters:
      listener - the listener to remove
    • getListeners

      List<ContinuousQueryListener<K,?>> getListeners()
      Get the list of currently registered listeners.
    • removeAllListeners

      void removeAllListeners()
      Unregisters all listeners.