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

RedisDomainEventBus

class RedisDomainEventBus : DistributedDomainEventBus, AbstractRedisMessageBus<DomainEventStream, EventStreamExchange>

Constructors

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

constructor(redisTemplate: ReactiveStringRedisTemplate, recoveryOptions: RedisStreamRecoveryOptions, observer: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, 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(subscription: MessageSubscription): Flux<EventStreamExchange>

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

send

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

toExchange

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