CampaignWorkerConfig

@Configuration

class CampaignWorkerConfig(redisTemplate: StringRedisTemplate)(source)

Configuração do Redis Stream para processamento de campanhas. Cria o consumer group e inicia o listener container.

Constructors

constructor(redisTemplate: StringRedisTemplate)

@Bean

fun campaignStreamContainer(connectionFactory: RedisConnectionFactory, campaignEventConsumer: CampaignEventConsumer): StreamMessageListenerContainer<String, ObjectRecord<String, String>>