Class InMemoryRealtimeBus

java.lang.Object

com.kingsrook.qqq.backend.core.realtime.InMemoryRealtimeBus

All Implemented Interfaces:

RealtimeBusInterface, AutoCloseable

public class InMemoryRealtimeBus
extends Object
implements RealtimeBusInterface, AutoCloseable

Synchronous fan-out on virtual threads; a failed listener never fails a write.

Constructor Summary

Constructors

Constructor	Description
InMemoryRealtimeBus()

Method Summary

Modifier and Type	Method	Description
void	close()	Release the executor and listeners.
void	publish(RealtimeMessage message)	Run each listener independently and await this publication.
AutoCloseable	subscribe(Consumer<RealtimeMessage> listener)	The subscription handle removes only this listener.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryRealtimeBus

public InMemoryRealtimeBus()

Method Details

publish

public void publish(RealtimeMessage message)

Run each listener independently and await this publication.

Specified by:

publish in interface RealtimeBusInterface

subscribe

public AutoCloseable subscribe(Consumer<RealtimeMessage> listener)

The subscription handle removes only this listener.

Specified by:

subscribe in interface RealtimeBusInterface

close

public void close()

Release the executor and listeners.

Specified by:

close in interface AutoCloseable