RedisDomainEventBus
class RedisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT) : TransportDomainEventBus
The domain event stream bus on Redis Streams: a TransportDomainEventBus 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: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2), recoveryOptions: RedisStreamRecoveryOptions = RedisStreamRecoveryOptions.DEFAULT, messageBusObserver: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, retentionOptions: RedisStreamRetentionOptions = RedisStreamRetentionOptions.DEFAULT, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT)