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

Package-level declarations

Types

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

class RedisCommandBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: CommandTopicConverter = DefaultCommandTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2)) : AbstractRedisMessageBus<CommandMessage<*>, ServerCommandExchange<*>> , DistributedCommandBus

class RedisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2)) : AbstractRedisMessageBus<DomainEventStream, EventStreamExchange> , DistributedDomainEventBus

data class RedisEventStreamExchange(val message: DomainEventStream, acknowledge: Mono<Void>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

class RedisServerCommandExchange<C : Any>(val message: CommandMessage<C>, acknowledge: Mono<Void>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>

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

class RedisStateEventExchange<C : Any>(val message: StateEvent<C>, acknowledge: Mono<Void>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<C>