Package-level declarations
Types
Link copied to clipboard
open class TransportStateEventBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<StateEvent<*>, StateEventExchange<*>> , DistributedStateEventBus
The distributed state event bus over a Transport.
Link copied to clipboard
class TransportStateEventExchange<S : Any>(val message: StateEvent<S>, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>