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

RedisCommandBus

class RedisCommandBus : DistributedCommandBus, AbstractRedisMessageBus<CommandMessage<*>, ServerCommandExchange<*>>

Constructors

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

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

Properties

messageType

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

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

receive

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

receiver

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

runtimeReceiver

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

send

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

toExchange

open override fun CommandMessage<*>.toExchange(acknowledgePublisher: Mono<Void>): ServerCommandExchange<*>