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

Package-level declarations

Types

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>

AggregateTopicConverter

fun interface AggregateTopicConverter

CommandTopicConverter

interface CommandTopicConverter : AggregateTopicConverter

CompositeRedisMessageBusObserver

class CompositeRedisMessageBusObserver(observers: Iterable<RedisMessageBusObserver>) : RedisMessageBusObserver

Dispatches each observation to an immutable observer snapshot in iteration order.

DefaultCommandTopicConverter

object DefaultCommandTopicConverter : CommandTopicConverter

DefaultEventStreamTopicConverter

object DefaultEventStreamTopicConverter : EventStreamTopicConverter

DefaultStateEventTopicConverter

object DefaultStateEventTopicConverter : StateEventTopicConverter

EventStreamTopicConverter

interface EventStreamTopicConverter : AggregateTopicConverter

RedisCommandBus

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

RedisDomainEventBus

class RedisDomainEventBus : DistributedDomainEventBus, AbstractRedisMessageBus<DomainEventStream, EventStreamExchange>

RedisEventStreamExchange

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

RedisMessageBusObservation

sealed interface RedisMessageBusObservation

Message payloads and Throwable instances are deliberately excluded so observers cannot retain sensitive payloads or failure object graphs.

RedisMessageBusObserver

fun interface RedisMessageBusObserver

Receives synchronous Redis message-bus recovery and decode observations.

RedisRecordDecodeFailureReason

enum RedisRecordDecodeFailureReason : Enum<RedisRecordDecodeFailureReason>

RedisServerCommandExchange

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

RedisStateEventBus

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

RedisStateEventExchange

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

RedisStreamRecoveryOptions

data class RedisStreamRecoveryOptions(val enabled: Boolean = true, val minIdleTime: Duration = Duration.ofMinutes(5), val interval: Duration = Duration.ofSeconds(30), val batchSize: Long = 100)

StateEventTopicConverter

interface StateEventTopicConverter : AggregateTopicConverter

Properties

const val MESSAGE_FIELD: String