Package-level declarations
Types
Link copied to clipboard
open class TransportDomainEventBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<DomainEventStream, EventStreamExchange> , DistributedDomainEventBus
The distributed domain event bus over a Transport.
Link copied to clipboard
class TransportEventStreamExchange(val message: DomainEventStream, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange