Package org.infinispan.notifications.cachelistener.cluster

Class ClusterListenerReplicateCallable<K,V>

java.lang.Object

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

All Implemented Interfaces:

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

public class ClusterListenerReplicateCallable<K,V>
extends Object
implements DistributedCallable<K,V,Void>

This DistributedCallable is used to install a RemoteClusterListener on the resulting node. This class also has checks to ensure that if the listener is attempted to be installed from more than 1 source only 1 will be installed as well if a node goes down while installing will also remove the listener.

Since:

7.0

Author:

wburns

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterListenerReplicateCallable.Externalizer

Constructor Summary

Constructors

Constructor	Description
ClusterListenerReplicateCallable(UUID identifier, Address origin, CacheEventFilter<K,V> filter, CacheEventConverter<K,V,?> converter, boolean sync, Set<Class<? extends Annotation>> filterAnnotations, DataConversion keyDataConversion, DataConversion valueDataConversion, boolean useStorageFormat)

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

ClusterListenerReplicateCallable

public ClusterListenerReplicateCallable(UUID identifier,
                                        Address origin,
                                        CacheEventFilter<K,V> filter,
                                        CacheEventConverter<K,V,?> converter,
                                        boolean sync,
                                        Set<Class<? extends Annotation>> filterAnnotations,
                                        DataConversion keyDataConversion,
                                        DataConversion valueDataConversion,
                                        boolean useStorageFormat)

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