QuettaCode API/com.quettacode.flow.config/FlowWorkerConfig

FlowWorkerConfig

@Configuration
class FlowWorkerConfig(redisTemplate: StringRedisTemplate)(source)

Constructors

Link copied to clipboard
constructor(redisTemplate: StringRedisTemplate)

Functions

Link copied to clipboard
@Bean
fun flowStreamContainer(connectionFactory: RedisConnectionFactory, flowEventConsumer: FlowEventConsumer): StreamMessageListenerContainer<String, ObjectRecord<String, String>>