wow-core/me.ahoo.wow.messaging.propagation/MessagePropagators

MessagePropagators

class MessagePropagators(propagators: List<MessagePropagator>)

The header propagation of one runtime: the propagators it runs, in @Order, whenever a message is derived from an upstream one (an event stream from its command, a command from the event a saga reacts to).

The runtime gets it injected: the Spring starter builds one bean from the ServiceLoader contributions (loadServices) and the application's MessagePropagator beans. DEFAULT holds the ServiceLoader contributions alone, for code that is not wired by a container. The set of keys the default propagators write is a frozen v9 wire contract, locked by the wire-format golden tests.

Constructors

MessagePropagators

constructor(propagators: List<MessagePropagator>)

Types

Companion

object Companion

Properties

propagators

val propagators: List<MessagePropagator>

Functions

propagate

fun propagate(header: Header, upstream: Message<*, *>)

Runs every propagator for a message derived from upstream.

fun propagate(header: Header, upstream: Message<*, *>, producer: FunctionInfo)

Runs every propagator for a message that producer derives from upstream.