Interface TopicEventCluster<E,N>
-
- Type Parameters:
E- The type of the events sent byTopicEventPublisherN- The type of the nodes in the cluster
- All Known Implementing Classes:
HazelcastTopicEventCluster
public interface TopicEventCluster<E,N>Represents a view of the Confluence cluster as used byTopicEventPublisher.- Since:
- 8.3
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanallNodesInitialised()Set<N>getOtherClusterMembers()voidinitialise(BiConsumer<N,E> eventListener, BiConsumer<N,UUID> ackListener, Consumer<N> nodeRemovedListener)Initialise the cluster with the given listeners.voidpublishAck(UUID ack)voidpublishEvent(E event)EwrapEvent(Object event)
-
-
-
Method Detail
-
allNodesInitialised
boolean allNodesInitialised()
-
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 clusterackListener- The listener that will receive event acknowledgements from the clusternodeRemovedListener- The listener that will receive notifications of cluster nodes being removed
-
publishEvent
void publishEvent(E event)
-
publishAck
void publishAck(UUID ack)
-
-