SimpleMessageFunctionRegistrar

Simple implementation of MessageFunctionRegistrar using a thread-safe set.

Provides basic registration and lookup functionality for message functions using a CopyOnWriteArraySet for thread safety.

Parameters

F

The type of message function being registered

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
open override val functions: Set<F>

Returns the set of registered functions.

Functions

Link copied to clipboard
open override fun register(function: F)

Registers a function and logs the registration.

Link copied to clipboard
open override fun <M : Message<*, Any>, NamedBoundedContext, NamedAggregate> supportedFunctions(message: M): Sequence<F>

Returns a sequence of functions that support the given message.

Link copied to clipboard
open override fun unregister(function: F)

Unregisters a function and logs the unregistration.