RedisStateEventBus
class RedisStateEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT) : TransportStateEventBus
The state event bus on Redis Streams: a TransportStateEventBus over a RedisStreamTransport, with streams from topicConverter. Undecodable entries are reported to messageBusObserver and stay pending (RedisRecordDecodeFailureHandler).
Constructors
Link copied to clipboard
constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT)