TransportStateEventBus
open class TransportStateEventBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<StateEvent<*>, StateEventExchange<*>> , DistributedStateEventBus
The distributed state event bus over a Transport.
Constructors
Link copied to clipboard
constructor(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL)