AbstractRedisMessageBus

abstract class AbstractRedisMessageBus<M : Message<*, *>, AggregateIdCapable, NamedAggregate, E : MessageExchange<*, M>>(redisTemplate: ReactiveStringRedisTemplate, topicConverter: AggregateTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2)) : DistributedMessageBus<M, E>

Constructors

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

open override fun close()

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

open override fun send(message: M): Mono<Void>

abstract fun M.toExchange(acknowledgePublisher: Mono<Void>): E