Uses of Class
com.kingsrook.qqq.backend.core.cluster.ClusterEvent

Packages that use ClusterEvent

Package	Description
com.kingsrook.qqq.backend.core.cluster
com.kingsrook.qqq.esb.cluster

Uses of ClusterEvent in com.kingsrook.qqq.backend.core.cluster

Methods in com.kingsrook.qqq.backend.core.cluster with parameters of type ClusterEvent

Modifier and Type	Method	Description
static void	ClusterBus.publish(QInstance instance, ClusterEvent event)	Publish an event: handled on this node now, and sent to the others.
void	ClusterBusInterface.publish(ClusterEvent event)	Send an event to every node.
void	InMemoryClusterBus.publish(ClusterEvent event)	Deliver to this JVM's subscribers.

Method parameters in com.kingsrook.qqq.backend.core.cluster with type arguments of type ClusterEvent

Modifier and Type	Method	Description
static void	ClusterBus.on(String type, BiConsumer<QInstance,ClusterEvent> handler)	Register a handler for an event type (it runs on every node).
AutoCloseable	ClusterBusInterface.subscribe(Consumer<ClusterEvent> listener)	Receive events from every node.
AutoCloseable	InMemoryClusterBus.subscribe(Consumer<ClusterEvent> listener)	Subscribe.

Uses of ClusterEvent in com.kingsrook.qqq.esb.cluster

Methods in com.kingsrook.qqq.esb.cluster with parameters of type ClusterEvent

Modifier and Type	Method	Description
void	EsbClusterBus.publish(ClusterEvent message)	Use a non-transacted, auto-ack session like the control topic.

Method parameters in com.kingsrook.qqq.esb.cluster with type arguments of type ClusterEvent

Modifier and Type	Method	Description
AutoCloseable	EsbClusterBus.subscribe(Consumer<ClusterEvent> listener)	Subscribe locally; the broker sends each message to every pod, including its producer.