InMemoryCommandBus

class InMemoryCommandBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>> = { Sinks.many().unicast().onBackpressureBuffer() }) : LocalCommandBus, InMemoryMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

InMemoryCommandBus .

ahoo wang

Constructors

constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>> = { Sinks.many().unicast().onBackpressureBuffer() })

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>>

一个命令只能有一个消费者，所以使用单播模式.

open override val topicKind: TopicKind

open override fun close()

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