Class ClusterListenerReplicateCallable<K,​V>

  • All Implemented Interfaces:
    java.util.concurrent.Callable<java.lang.Void>, DistributedCallable<K,​V,​java.lang.Void>

    public class ClusterListenerReplicateCallable<K,​V>
    extends java.lang.Object
    implements DistributedCallable<K,​V,​java.lang.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
    • Constructor Detail

      • ClusterListenerReplicateCallable

        public ClusterListenerReplicateCallable​(java.util.UUID identifier,
                                                Address origin,
                                                CacheEventFilter<K,​V> filter,
                                                CacheEventConverter<K,​V,​?> converter,
                                                boolean sync,
                                                java.util.Set<java.lang.Class<? extends java.lang.annotation.Annotation>> filterAnnotations,
                                                DataConversion keyDataConversion,
                                                DataConversion valueDataConversion,
                                                boolean useStorageFormat)
    • Method Detail

      • setEnvironment

        public void setEnvironment​(Cache<K,​V> cache,
                                   java.util.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,​java.lang.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 java.lang.Void call()
                            throws java.lang.Exception
        Specified by:
        call in interface java.util.concurrent.Callable<K>
        Throws:
        java.lang.Exception