QuettaCode API/com.quettacode.flow.campaign/CampaignEventProducer

CampaignEventProducer

@Service
class CampaignEventProducer(redisTemplate: StringRedisTemplate, objectMapper: ObjectMapper)(source)

Producer Redis para enfileirar tarefas de envio de campanhas. Usa Redis Streams para processamento assíncrono e não travar o servidor.

Constructors

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

Functions

Link copied to clipboard
fun enqueueCampaignSend(event: CampaignSendEvent)

Enfileira uma campanha para envio assíncrono. O worker irá processar e enviar as mensagens para cada contato.