Package org.infinispan.notifications.cachelistener.cluster

Class ClusterListenerReplicateCallable<K,V>

java.lang.Object

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

All Implemented Interfaces:

BiConsumer<EmbeddedCacheManager,Cache<K,V>>, Function<EmbeddedCacheManager,Void>

public class ClusterListenerReplicateCallable<K,V>
extends Object
implements Function<EmbeddedCacheManager,Void>, BiConsumer<EmbeddedCacheManager,Cache<K,V>>

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(String cacheName, 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	accept(EmbeddedCacheManager cacheManager, Cache<K,V> cache)
Void	apply(EmbeddedCacheManager cacheManager)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.BiConsumer

andThen

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Detail

ClusterListenerReplicateCallable

public ClusterListenerReplicateCallable(String cacheName,
                                        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

apply

public Void apply(EmbeddedCacheManager cacheManager)

Specified by:

apply in interface Function<K,V>

accept

public void accept(EmbeddedCacheManager cacheManager,
                   Cache<K,V> cache)

Specified by:

accept in interface BiConsumer<K,V>

toString

public String toString()

Overrides:

toString in class Object