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>

@ProtoTypeId(1057)
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

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 Object

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

Methods inherited from interface BiConsumer

andThen

Methods inherited from interface Function

andThen, compose

Constructor Details

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 Details

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