Package org.infinispan.query.api.continuous

Interface ContinuousQueryListener<K,​V>

  • public interface ContinuousQueryListener<K,​V>
    Listener for continuous query events.
    Since:
    8.2
    Author:
    anistor@redhat.com

    • Method Summary

      All Methods Instance Methods Default Methods 
      Modifier and Type Method Description
      default void resultJoining​(K key, V value)
      Receives notification that a cache entry has joined the matching set.
      default void resultLeaving​(K key)
      Receives notification that a cache entry has left the matching set.
      default void resultUpdated​(K key, V value)
      Receives notification that a cache entry from the matching set was updated and continues to match the query.

    • Method Detail

      • resultJoining

        default void resultJoining​(K key,
                           V value)
        Receives notification that a cache entry has joined the matching set. This is invoked initially when receiving the existing entries that match the query and subsequently whenever a previously non-matching entry is updated and starts to match.
        Parameters:
        key - the key of the joining entry
        value - the joining entry or the Object[] projection if a projection was specified

      • resultUpdated

        default void resultUpdated​(K key,
                           V value)
        Receives notification that a cache entry from the matching set was updated and continues to match the query. The modified attributes causing this update are not necessarily part of the query.
        Parameters:
        key - the key of the joining entry
        value - the joining entry or the Object[] projection if specified

      • resultLeaving

        default void resultLeaving​(K key)
        Receives notification that a cache entry has left the matching set. This can happen due to an update or removal.
        Parameters:
        key - the key of the leaving entry