Class ClusterEventCallable<K,V>
- java.lang.Object
-
- org.infinispan.notifications.cachelistener.cluster.ClusterEventCallable<K,V>
-
- All Implemented Interfaces:
Callable<Void>,DistributedCallable<K,V,Void>
public class ClusterEventCallable<K,V> extends Object implements DistributedCallable<K,V,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
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classClusterEventCallable.Externalizer
-
Constructor Summary
Constructors Constructor Description ClusterEventCallable(UUID identifier, Collection<? extends ClusterEvent<K,V>> events)ClusterEventCallable(UUID identifier, ClusterEvent<K,V> event)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Voidcall()voidsetEnvironment(Cache<K,V> cache, Set<K> inputKeys)Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.StringtoString()
-
-
-
Constructor Detail
-
ClusterEventCallable
public ClusterEventCallable(UUID identifier, ClusterEvent<K,V> event)
-
ClusterEventCallable
public ClusterEventCallable(UUID identifier, Collection<? extends ClusterEvent<K,V>> events)
-
-
Method Detail
-
setEnvironment
public void setEnvironment(Cache<K,V> cache, Set<K> inputKeys)
Description copied from interface:DistributedCallableInvoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.- Specified by:
setEnvironmentin interfaceDistributedCallable<K,V,Void>- Parameters:
cache- cache whose keys are used as input data for this DistributedCallable taskinputKeys- keys used as input for this DistributedCallable task
-
-