Interface ClusterEventManager<K,V>

All Known Implementing Classes:
BatchingClusterEventManagerImpl, ClusterEventManagerStub

public interface ClusterEventManager<K,V>
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addEvents(Object batchIdentifier, Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)
    Adds additional cluster events that need to be sent remotely for an event originating locally.
    void
    dropEvents(Object batchIdentifier)
    Drops and ignores all previously added events for the given identifier.
    sendEvents(Object batchIdentifier)
    Sends all previously added events for the given identifier
  • Method Details

    • addEvents

      void addEvents(Object batchIdentifier, Address target, UUID identifier, 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 batched by the batchIdentifier pending their submission when sendEvents(Object) is invoked or cancelled when dropEvents(Object) is invoked.
      Parameters:
      batchIdentifier - identifier for the batch
      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

      CompletionStage<Void> sendEvents(Object batchIdentifier)
      Sends all previously added events for the given identifier
    • dropEvents

      void dropEvents(Object batchIdentifier)
      Drops and ignores all previously added events for the given identifier.