Package com.onec.cluster

Class NoOpClusterEventBus

java.lang.Object

com.onec.cluster.NoOpClusterEventBus

All Implemented Interfaces:

ClusterEventBus

public final class NoOpClusterEventBus
extends Object
implements ClusterEventBus

Local-only ClusterEventBus used when no cross-node transport is configured — a single-node deployment, a non-Postgres (e.g. H2) datasource, or onec.cluster.enabled=false.

publish(com.onec.cluster.ClusterEvent) is inert (nothing leaves the JVM) and subscribe(java.util.function.Consumer<com.onec.cluster.ClusterEvent>) never fires (no remote events ever arrive), so wiring it changes nothing: the local SSE fan-out on the change path is the whole story, exactly as before this bus existed.

Constructor Summary

Constructors

Constructor	Description
NoOpClusterEventBus()

Method Summary

Modifier and Type	Method	Description
boolean	isDistributed()	Whether this bus actually crosses node boundaries.
void	publish(ClusterEvent event)	Publish a change to peer nodes.
void	subscribe(Consumer<ClusterEvent> sink)	Register a sink invoked for events that originated on other nodes.

Methods inherited from class java.lang.Object

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

Constructor Details

NoOpClusterEventBus

public NoOpClusterEventBus()

Method Details

publish

public void publish(ClusterEvent event)

Description copied from interface: ClusterEventBus

Publish a change to peer nodes. Fan-out to the publishing node's own SSE clients has already happened synchronously on the local event path, so an implementation that echoes the event back to its own subscribers must let them filter it by ClusterEvent.originNodeId().

The implementation stamps the event's ClusterEvent.originNodeId() with its own node id before sending (see ClusterEvent.withOrigin(java.lang.String)); callers may leave that field null (as ClusterEvent.entityChanged(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) does).

Specified by:

publish in interface ClusterEventBus

subscribe

public void subscribe(Consumer<ClusterEvent> sink)

Description copied from interface: ClusterEventBus

Register a sink invoked for events that originated on other nodes. A bus must not invoke the sink for the local node's own events (see ClusterEvent.originNodeId()). May be called more than once to attach multiple sinks.

Specified by:

subscribe in interface ClusterEventBus

isDistributed

public boolean isDistributed()

Description copied from interface: ClusterEventBus

Whether this bus actually crosses node boundaries. false for NoOpClusterEventBus (single-node / non-Postgres dev), true for a real distributed implementation. Useful for diagnostics and for callers that want to log the active topology at startup.

Specified by:

isDistributed in interface ClusterEventBus