wow-opentelemetry/me.ahoo.wow.opentelemetry.wait/TracingCommandGateway

TracingCommandGateway

class TracingCommandGateway(val delegate: CommandGateway) : Traced, CommandGateway, Decorator<CommandGateway>

Constructors

TracingCommandGateway

constructor(delegate: CommandGateway)

Properties

open override val delegate: CommandGateway

enforcesCommandWaitTimeout

open override val enforcesCommandWaitTimeout: Boolean

open override val topicKind: TopicKind

Functions

open override fun close()

open override fun receive(subscription: MessageSubscription): Flux<ServerCommandExchange<*>>

open override fun receiver(subscription: MessageSubscription): MessageReceiver<ServerCommandExchange<*>>

runtimeReceiver

open override fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<ServerCommandExchange<*>>

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

open override fun <C : Any> sendAndWait(command: CommandMessage<C>, waitPlan: WaitPlan): Mono<CommandResult>

sendAndWaitForProcessed

open fun <C : Any> sendAndWaitForProcessed(command: CommandMessage<C>): Mono<CommandResult>

sendAndWaitForSent

open fun <C : Any> sendAndWaitForSent(command: CommandMessage<C>): Mono<CommandResult>

sendAndWaitForSnapshot

open fun <C : Any> sendAndWaitForSnapshot(command: CommandMessage<C>): Mono<CommandResult>

sendAndWaitStream

open override fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitPlan: WaitPlan): Flux<CommandResult>

fun CommandGateway.tracing(): CommandGateway