Class MultiClusterEventCallable<K,​V>

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

    public class MultiClusterEventCallable<K,​V>
    extends java.lang.Object
    implements DistributedCallable<K,​V,​java.lang.Void>
    This DistributedCallable is used to invoke a raised notification on the cluster listener that registered to listen for this event.
    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

      • MultiClusterEventCallable

        public MultiClusterEventCallable​(java.util.Map<java.util.UUID,​java.util.Collection<ClusterEvent<K,​V>>> events)
    • Method Detail

      • call

        public java.lang.Void call()
                            throws java.lang.Exception
        Specified by:
        call in interface java.util.concurrent.Callable<K>
        Throws:
        java.lang.Exception
      • 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