wow-core/me.ahoo.wow.metrics/MetricLocalCommandBus

MetricLocalCommandBus

class MetricLocalCommandBus(delegate: LocalCommandBus) : MetricCommandBus<LocalCommandBus> , LocalCommandBus

Metric decorator specifically for local command buses. Extends MetricCommandBus to provide metrics collection for local command bus operations while maintaining the LocalCommandBus interface.

Constructors

constructor(delegate: LocalCommandBus)

Properties

delegate

override val delegate: LocalCommandBus

the original component being decorated, must implement the Decorator interface

source

val source: String

The source identifier derived from the original delegate's class name. This is used for metrics tagging to identify the component type.

topicKind

open override val topicKind: TopicKind

The topic kind for command messages, always returns TopicKind.COMMAND

Functions

open override fun close()

Closes the command bus and releases any resources. This delegates to the underlying command bus implementation.

metrizable

fun LocalCommandBus.metrizable(): LocalCommandBus

Wraps a LocalCommandBus with metrics collection capabilities. Returns a MetricLocalCommandBus that collects metrics on command operations.

receive

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<ServerCommandExchange<*>>

Receives command exchanges for the specified named aggregates and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification and subscriber information.

send

open override fun send(message: CommandMessage<*>): Mono<Void>

Sends a command message and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate and command identification.

subscriberCount

open override fun subscriberCount(namedAggregate: NamedAggregate): Int

Returns the number of subscribers for the specified named aggregate. This delegates to the underlying local command bus implementation.

tagSource

fun <M> Flux<M>.tagSource(): Flux<M>

Extension function to tag a Flux publisher with the current source identifier. This adds the source tag to metrics collected from this reactive stream.

fun <M> Mono<M>.tagSource(): Mono<M>

Extension function to tag a Mono publisher with the current source identifier. This adds the source tag to metrics collected from this reactive stream.