Package at.aimon.session.web.spi.inmemory

Class InMemorySignalBus

java.lang.Object

at.aimon.session.web.spi.inmemory.InMemorySignalBus

All Implemented Interfaces:

ConversationSignalBus

public final class InMemorySignalBus
extends Object
implements ConversationSignalBus

Single-process ConversationSignalBus backed by per-conversation subscriber lists.

Each subscribe appends to a CopyOnWriteArrayList so publish(at.aimon.session.web.spi.ConversationSignal) can iterate without locking. Handlers run synchronously on the publisher thread — callers must keep them non-blocking. Suitable for SINGLE_NODE deployments and unit tests.

Nested Class Summary

Nested classes/interfaces inherited from interface at.aimon.session.web.spi.ConversationSignalBus

ConversationSignalBus.Subscription

Constructor Summary

Constructors

Constructor	Description
InMemorySignalBus()

Method Summary

Modifier and Type	Method	Description
void	publish(ConversationSignal signal)	Publish a signal.
ConversationSignalBus.Subscription	subscribe(at.aimon.core.agent.conversation.ConversationId id, Consumer<ConversationSignal> handler)	Subscribe to signals targeting id.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemorySignalBus

public InMemorySignalBus()

Method Details

subscribe

public ConversationSignalBus.Subscription subscribe(at.aimon.core.agent.conversation.ConversationId id,
 Consumer<ConversationSignal> handler)

Description copied from interface: ConversationSignalBus

Subscribe to signals targeting id.

Specified by:

subscribe in interface ConversationSignalBus

Parameters:

id - the conversation to subscribe to (must not be null)

handler - invoked for every signal received (must not be null)

Returns:

a ConversationSignalBus.Subscription the caller closes to unsubscribe

publish

public void publish(ConversationSignal signal)

Description copied from interface: ConversationSignalBus

Publish a signal. Idempotent w.r.t. duplicate delivery — receivers must be able to handle the same signal repeatedly.

Specified by:

publish in interface ConversationSignalBus

Parameters:

signal - the signal to publish (must not be null)