Package org.infinispan.notifications.cachelistener.cluster

Interface ClusterCacheNotifier<K,V>

All Superinterfaces:
CacheNotifier<K,V>, ClassLoaderAwareFilteringListenable<K,V>, ClassLoaderAwareListenable, DataConversionAwareListenable<K,V>, FilteringListenable<K,V>, Listenable
All Known Implementing Classes:
CacheNotifierImpl
public interface ClusterCacheNotifier<K,V> extends CacheNotifier<K,V>
This interface describes methods required for a cluster listener to be able to be bootstrapped and properly notified when a new event has been raised from the cluster.
Since:
7.0
Author:
wburns

  • Method Details

    • notifyClusterListeners

      CompletionStage<Void> notifyClusterListeners(Collection<ClusterEvent<K,V>> events, UUID listenerId)
      Method that is invoked on the node that has the given cluster listener that when registered generated the given listenerId. Note this will notify only cluster listeners and regular listeners are not notified of the events. Will fire the events in the order of the iteration of the collection.
      Parameters:
      events -
      listenerId -

    • retrieveClusterListenerCallablesToInstall

      Collection<ClusterListenerReplicateCallable<K,V>> retrieveClusterListenerCallablesToInstall()
      This method is invoked so that this node can send the details required for a new node to be bootstrapped with the existing cluster listeners that are already installed.
      Returns:
      A collection of callables that should be invoked on the new node to properly install cluster listener information