wow-redis/me.ahoo.wow.redis.bus/RedisDomainEventBus

RedisDomainEventBus

class RedisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2)) : DistributedDomainEventBus, AbstractRedisMessageBus<DomainEventStream, EventStreamExchange>

Constructors

RedisDomainEventBus

constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2))

Properties

messageType

open override val messageType: Class<DomainEventStream>

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

receive

open fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

send

open fun send(message: DomainEventStream): Mono<Void>

toExchange

open override fun DomainEventStream.toExchange(acknowledgePublisher: Mono<Void>): EventStreamExchange