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 Summary

Modifier and Type	Method and Description
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.
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.

Methods inherited from interface org.infinispan.notifications.cachelistener.CacheNotifier

hasListener, notifyCacheEntriesEvicted, notifyCacheEntryActivated, notifyCacheEntryCreated, notifyCacheEntryExpired, notifyCacheEntryInvalidated, notifyCacheEntryLoaded, notifyCacheEntryModified, notifyCacheEntryPassivated, notifyCacheEntryRemoved, notifyCacheEntryVisited, notifyDataRehashed, notifyPartitionStatusChanged, notifyPersistenceAvailabilityChanged, notifyTopologyChanged, notifyTransactionCompleted, notifyTransactionRegistered

Methods inherited from interface org.infinispan.notifications.DataConversionAwareListenable

addFilteredListener, addFilteredListenerAsync, addListener, addListenerAsync

Methods inherited from interface org.infinispan.notifications.ClassLoaderAwareFilteringListenable

addListener, addListenerAsync

Methods inherited from interface org.infinispan.notifications.FilteringListenable

addFilteredListener, addFilteredListenerAsync, addListener, addListenerAsync, addStorageFormatFilteredListener, addStorageFormatFilteredListenerAsync

Methods inherited from interface org.infinispan.notifications.Listenable

addListener, addListenerAsync, getListeners, removeListener, removeListenerAsync

Methods inherited from interface org.infinispan.notifications.ClassLoaderAwareListenable

addListener, addListenerAsync

Method Detail

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