RedisCommandBus
class RedisCommandBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: CommandTopicConverter = DefaultCommandTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT) : TransportCommandBus
The command bus on Redis Streams: a TransportCommandBus 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: CommandTopicConverter = DefaultCommandTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT)