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

RedisDomainEventBus

class RedisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP) : DistributedDomainEventBus, AbstractRedisMessageBus<DomainEventStream, EventStreamExchange>

Constructors

Link copied to clipboard
constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP)

Properties

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

Functions

Link copied to clipboard
open override fun DomainEventStream.toExchange(acknowledgePublisher: Mono<Void>): EventStreamExchange
Generated by Dokka
© 2026 Copyright