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

RedisStateEventBus

class RedisStateEventBus : DistributedStateEventBus, AbstractRedisMessageBus<StateEvent<*>, StateEventExchange<*>>

Constructors

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

constructor(redisTemplate: ReactiveStringRedisTemplate, recoveryOptions: RedisStreamRecoveryOptions, observer: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2))

Properties

messageType

open override val messageType: Class<StateEvent<*>>

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

receive

open fun receive(subscription: MessageSubscription): Flux<StateEventExchange<*>>

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<StateEventExchange<*>>

send

open fun send(message: StateEvent<*>): Mono<Void>

toExchange

open override fun StateEvent<*>.toExchange(acknowledgePublisher: Mono<Void>): StateEventExchange<*>