Package org.infinispan.notifications.cachelistener.cluster

Class ClusterListenerRemoveCallable<K,V>

java.lang.Object

org.infinispan.notifications.cachelistener.cluster.ClusterListenerRemoveCallable<K,V>

All Implemented Interfaces:

Callable<Void>, DistributedCallable<K,V,Void>

public class ClusterListenerRemoveCallable<K,V>
extends Object
implements DistributedCallable<K,V,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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterListenerRemoveCallable.Externalizer

Constructor Summary

Constructors

Constructor	Description
ClusterListenerRemoveCallable(UUID identifier)

Method Summary

Modifier and Type	Method	Description
Void	call()
void	setEnvironment(Cache<K,V> cache, 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(UUID identifier)

Method Detail

setEnvironment

public void setEnvironment(Cache<K,V> cache,
                           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,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 Void call()
          throws Exception

Specified by:

call in interface Callable<K>

Throws:

Exception