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 aRemoteClusterListener
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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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)
-
accept
public void accept(EmbeddedCacheManager cacheManager, Cache<K,V> cache)
- Specified by:
accept
in interfaceBiConsumer<K,V>
-
-