Package org.infinispan.notifications.cachelistener.cluster

Interface ClusterEventManager<K,​V>

  • public interface ClusterEventManager<K,​V>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void addEvents​(Address target, java.util.UUID identifier, java.util.Collection<ClusterEvent<K,​V>> events, boolean sync)
      Adds additional cluster events that need to be sent remotely for an event originating locally.
      void dropEvents()
      Drops and ignores all previously added events on this thread.
      java.util.concurrent.CompletionStage<java.lang.Void> sendEvents()
      Sends all previously added events on this thread

    • Method Detail

      • addEvents

        void addEvents​(Address target,
               java.util.UUID identifier,
               java.util.Collection<ClusterEvent<K,​V>> events,
               boolean sync)
        Adds additional cluster events that need to be sent remotely for an event originating locally. These events are not sent at time of registering but rather after the sendEvents() is invoked. These events are gathered on a per thread basis and batched to reduce number of RPCs required.
        Parameters:
        target - The target node this event was meant for
        identifier - The cluster listener that is identified for these events
        events - The events that were generated
        sync - Whether these events need to be sent synchronously or not

      • sendEvents

        java.util.concurrent.CompletionStage<java.lang.Void> sendEvents()
                                                         throws CacheException
        Sends all previously added events on this thread
        Throws:
        CacheException

      • dropEvents

        void dropEvents()
        Drops and ignores all previously added events on this thread.