Interface TopicEventCluster<E,​N>

    • Method Detail

      • 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)