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

RedisStateEventBus

class RedisStateEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2)) : DistributedStateEventBus, AbstractRedisMessageBus<StateEvent<*>, StateEventExchange<*>>

Constructors

RedisStateEventBus

constructor(redisTemplate: ReactiveStringRedisTemplate, 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(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

send

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

toExchange

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