Class ClusterListenerRemoveCallable<K,V>
- java.lang.Object
-
- org.infinispan.notifications.cachelistener.cluster.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 registeredRemoteClusterListener
on each of the various nodes when a cluster listener is unregistered from the cache.- Since:
- 7.0
- Author:
- wburns
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ClusterListenerRemoveCallable.Externalizer
-
Constructor Summary
Constructors Constructor Description ClusterListenerRemoveCallable(java.util.UUID identifier)
-
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.
-
-
-
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 interfaceDistributedCallable<K,V,java.lang.Void>
- Parameters:
cache
- cache whose keys are used as input data for this DistributedCallable taskinputKeys
- keys used as input for this DistributedCallable task
-
call
public java.lang.Void call() throws java.lang.Exception
- Specified by:
call
in interfacejava.util.concurrent.Callable<K>
- Throws:
java.lang.Exception
-
-