AbstractRedisMessageBus

constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: AggregateTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2))