TransportCommandBus
open class TransportCommandBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<CommandMessage<*>, ServerCommandExchange<*>> , DistributedCommandBus
The distributed command bus over a Transport.
Constructors
Link copied to clipboard
constructor(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL)