TransportDomainEventBus
open class TransportDomainEventBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<DomainEventStream, EventStreamExchange> , DistributedDomainEventBus
The distributed domain event bus over a Transport.
Constructors
Link copied to clipboard
constructor(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL)