Class ClusterListenerRemoveCallable<K,​V>

  • All Implemented Interfaces:
    java.util.concurrent.Callable<java.lang.Void>, DistributedCallable<K,​V,​java.lang.Void>

    public class ClusterListenerRemoveCallable<K,​V>
    extends java.lang.Object
    implements DistributedCallable<K,​V,​java.lang.Void>
    This DistributedCallable is used to remove registered RemoteClusterListener on each of the various nodes when a cluster listener is unregistered from the cache.
    Since:
    7.0
    Author:
    wburns
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.Void call()  
      void setEnvironment​(Cache<K,​V> cache, java.util.Set<K> inputKeys)
      Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ClusterListenerRemoveCallable

        public ClusterListenerRemoveCallable​(java.util.UUID identifier)
    • Method Detail

      • setEnvironment

        public void setEnvironment​(Cache<K,​V> cache,
                                   java.util.Set<K> inputKeys)
        Description copied from interface: DistributedCallable
        Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.
        Specified by:
        setEnvironment in interface DistributedCallable<K,​V,​java.lang.Void>
        Parameters:
        cache - cache whose keys are used as input data for this DistributedCallable task
        inputKeys - keys used as input for this DistributedCallable task
      • call

        public java.lang.Void call()
                            throws java.lang.Exception
        Specified by:
        call in interface java.util.concurrent.Callable<K>
        Throws:
        java.lang.Exception