CampaignEventConsumer

@Component

class CampaignEventConsumer(objectMapper: ObjectMapper, campaignRepository: CampaignRepository, contactRepository: ContactRepository, groupRepository: GroupRepository, channelRepository: ChannelRepository, messageRepository: MessageRepository, metaClient: MetaClient, notificationService: NotificationService, flowMessageService: FlowMessageService, redisTemplate: StringRedisTemplate) : StreamListener<String, ObjectRecord<String, String>> (source)

Consumer Redis que processa campanhas de envio. Cada campanha enfileirada é processada aqui, enviando templates para cada contato.

Constructors

constructor(objectMapper: ObjectMapper, campaignRepository: CampaignRepository, contactRepository: ContactRepository, groupRepository: GroupRepository, channelRepository: ChannelRepository, messageRepository: MessageRepository, metaClient: MetaClient, notificationService: NotificationService, flowMessageService: FlowMessageService, redisTemplate: StringRedisTemplate)

open override fun onMessage(message: ObjectRecord<String, String>)