flowStreamContainer

@Bean
fun flowStreamContainer(connectionFactory: RedisConnectionFactory, flowEventConsumer: FlowEventConsumer): StreamMessageListenerContainer<String, ObjectRecord<String, String>>(source)