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 -
Constructor Summary
ConstructorsConstructorDescriptionClusterListenerReplicateCallable
(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 TypeMethodDescriptionvoid
accept
(EmbeddedCacheManager cacheManager, Cache<K, V> cache) apply
(EmbeddedCacheManager cacheManager) 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 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