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

AbstractRedisMessageBus

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

Inheritors

RedisCommandBus

RedisDomainEventBus

RedisStateEventBus

Constructors

AbstractRedisMessageBus

constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: AggregateTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP)

Types

object Companion

Properties

abstract val messageType: Class<M>

Functions

open override fun close()

open override fun receive(subscription: MessageSubscription): Flux<E>

open override fun receiver(subscription: MessageSubscription): MessageReceiver<E>

runtimeReceiver

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

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

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