Package com.atlassian.confluence.impl.cluster.nutcluster.event

Class NutclusterTopicEventCluster

java.lang.Object

com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEventCluster

All Implemented Interfaces:

TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

public final class NutclusterTopicEventCluster
extends Object
implements TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

An implementation of TopicEventCluster representing the Nutcluster cluster.

Since:

8.3

Constructor Summary

Constructors

Constructor	Description
NutclusterTopicEventCluster(com.atlassian.nutcluster.core.NutclusterInstance nutcluster)

Method Summary

Modifier and Type	Method	Description
Set<com.atlassian.nutcluster.core.Member>	getOtherClusterMembers()
void	initialise(BiConsumer<com.atlassian.nutcluster.core.Member,com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent> eventListener, BiConsumer<com.atlassian.nutcluster.core.Member,UUID> ackListener, Consumer<com.atlassian.nutcluster.core.Member> nodeRemovedListener)	Initialise the cluster with the given listeners.
void	publishAck(UUID ack)
void	publishEvent(com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent event)
com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent	wrapEvent(Object event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NutclusterTopicEventCluster

public NutclusterTopicEventCluster(com.atlassian.nutcluster.core.NutclusterInstance nutcluster)

Method Details

initialise

public void initialise(BiConsumer<com.atlassian.nutcluster.core.Member,com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent> eventListener,
 BiConsumer<com.atlassian.nutcluster.core.Member,UUID> ackListener,
 Consumer<com.atlassian.nutcluster.core.Member> nodeRemovedListener)

Description copied from interface: TopicEventCluster

Initialise the cluster with the given listeners.

Specified by:

initialise in interface TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

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

public Set<com.atlassian.nutcluster.core.Member> getOtherClusterMembers()

Specified by:

getOtherClusterMembers in interface TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

publishEvent

public void publishEvent(com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent event)

Specified by:

publishEvent in interface TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

publishAck

public void publishAck(UUID ack)

Specified by:

publishAck in interface TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>

wrapEvent

public com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent wrapEvent(Object event)

Specified by:

wrapEvent in interface TopicEventCluster<com.atlassian.confluence.impl.cluster.nutcluster.event.NutclusterTopicEvent,com.atlassian.nutcluster.core.Member>