Interface TopicEventCluster<E,N>

Type Parameters:
E - The type of the events sent by TopicEventPublisher
N - The type of the nodes in the cluster
All Known Implementing Classes:
NutclusterTopicEventCluster

public interface TopicEventCluster<E,N>
Represents a view of the Confluence cluster as used by TopicEventPublisher.
Since:
8.3
  • Method Details

    • initialise

      void initialise(BiConsumer<N,E> eventListener, BiConsumer<N,UUID> ackListener, Consumer<N> nodeRemovedListener)
      Initialise the cluster with the given listeners.
      Parameters:
      eventListener - The listener that will consume events received from the cluster
      ackListener - The listener that will receive event acknowledgements from the cluster
      nodeRemovedListener - The listener that will receive notifications of cluster nodes being removed
    • getOtherClusterMembers

      Set<N> getOtherClusterMembers()
    • publishEvent

      void publishEvent(E event)
    • publishAck

      void publishAck(UUID ack)
    • wrapEvent

      E wrapEvent(Object event)