QuettaCode API/com.quettacode.flow.worker/FlowEventConsumer

FlowEventConsumer

@Component
class FlowEventConsumer(objectMapper: ObjectMapper, flowMessageService: FlowMessageService, redisTemplate: StringRedisTemplate) : StreamListener<String, ObjectRecord<String, String>> (source)

Constructors

Link copied to clipboard
constructor(objectMapper: ObjectMapper, flowMessageService: FlowMessageService, redisTemplate: StringRedisTemplate)

Functions

Link copied to clipboard
open override fun onMessage(message: ObjectRecord<String, String>)