Class InMemoryClusterBus

java.lang.Object

com.kingsrook.qqq.backend.core.cluster.InMemoryClusterBus

All Implemented Interfaces:

ClusterBusInterface

public class InMemoryClusterBus
extends Object
implements ClusterBusInterface

A single-node cluster bus: events never leave this JVM. The default, so a single-node application behaves exactly as before.

Constructor Summary

Constructors

Constructor	Description
InMemoryClusterBus()

Method Summary

Modifier and Type	Method	Description
void	publish(ClusterEvent event)	Deliver to this JVM's subscribers.
AutoCloseable	subscribe(Consumer<ClusterEvent> listener)	Subscribe.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryClusterBus

public InMemoryClusterBus()

Method Details

publish

public void publish(ClusterEvent event)

Deliver to this JVM's subscribers.

Specified by:

publish in interface ClusterBusInterface

subscribe

public AutoCloseable subscribe(Consumer<ClusterEvent> listener)

Subscribe.

Specified by:

subscribe in interface ClusterBusInterface