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

RedisDomainEventBus

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

Constructors

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

Properties

Link copied to clipboard
open override val messageType: Class<DomainEventStream>
Link copied to clipboard
open override val topicKind: TopicKind

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>
Link copied to clipboard
abstract fun send(message: DomainEventStream): Mono<Void>
Link copied to clipboard
open override fun DomainEventStream.toExchange(acknowledgePublisher: Mono<Void>): EventStreamExchange