The broker resolved from CAPABILITIES.MESSAGING
This instance's identity
The topic every instance shares
Optionalreporter: IRealtimeHandlerErrorReporter
Optional subscriber failure and recovery sink; history is always retained
OptionalisM70c: delegates to the resolved broker's isHealthy?() — the only way the
backplane can report the broker's reachability without importing the
messaging plugin (§3.1). Assigned only when the broker provides the
member: a broker that omits it is unknown, and the indicator reads
absence of isHealthy (not false) as that.
M90b (X21-1): the delegation calls through the OWNER —
broker.isHealthy(), not a detached const probe = broker.isHealthy
reference. A broker whose isHealthy reads instance state
(ServiceBusBroker's private probe cache, among others) throws a bare
TypeError when invoked unbound, which a health endpoint then reports
as an error rather than a fact. It retains the resolved broker's own
probe cache rather than adding a duplicate backplane-level cache.
ReadonlyoriginThis instance's identity, stamped onto every frame it publishes.
Stable for the lifetime of the instance and distinct from every peer's.
The most recent 100 errors thrown by subscribers during delivery, oldest first.
Closes the underlying transport and drops every handler.
Opens the underlying transport. Idempotent.
Publishes a frame to every other subscribed instance.
The frame is not delivered back to this instance's own handlers — a local broadcast has already reached local members directly, and redelivering it would double-send.
The frame to publish
Registers a handler for frames arriving from other instances.
May be called more than once; each consumer plugin registers its own.
Invoked per arriving frame
A function that removes this handler
Carries frames over whatever broker is registered under
CAPABILITIES.MESSAGING.This reuses every broker the messaging plugin already ships — in-memory, Redis Streams, RabbitMQ, NATS, Kafka — and adds no dependency of its own. The broker's own
connect/disconnectare left to its owning plugin; this transport only publishes and subscribes.Since
0.2.0