feat(campaign-sender): campaigns.send consumer with tabular idempotency and pause/stop recheck (EVO-1217) by nickoliveira23 · Pull Request #47 · evolution-foundation/evo-flow-community

feat(broker): add getTopicLag for consumer lag observability (EVO-1217)

nickoliveira23

and

claude

committed

feat(campaign-sender): batch dispatcher with template rendering via CRM inbox (EVO-1217)

nickoliveira23

and

claude

committed

feat(campaign-sender): sender service with tabular idempotency and pause recheck (EVO-1217)

nickoliveira23

and

claude

committed

feat(campaign-sender): module and campaigns.send consumer with metrics (EVO-1217)

nickoliveira23

and

claude

committed

feat(campaign-sender): wire RUN_MODE=campaign-sender replacing the 1.1 stub (EVO-1217)

nickoliveira23

and

claude

committed

fix(broker): use assertQueue in RabbitMQ getTopicLag to avoid channel-closing 404 (EVO-1217)

nickoliveira23

and

claude

committed

fix(campaign-sender): review findings — pending-only hydration, dedupe, cache bound (EVO-1217)

nickoliveira23

and

claude

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat(campaign-sender): campaigns.send consumer with tabular idempotency and pause/stop recheck (EVO-1217)#47

feat(campaign-sender): campaigns.send consumer with tabular idempotency and pause/stop recheck (EVO-1217)#47
dpaes merged 7 commits into
developfrom
feat/EVO-1217

Commits on Jun 10, 2026

feat(broker): add getTopicLag for consumer lag observability (EVO-1217)

feat(campaign-sender): batch dispatcher with template rendering via CRM inbox (EVO-1217)

feat(campaign-sender): sender service with tabular idempotency and pause recheck (EVO-1217)

feat(campaign-sender): module and campaigns.send consumer with metrics (EVO-1217)

feat(campaign-sender): wire RUN_MODE=campaign-sender replacing the 1.1 stub (EVO-1217)

fix(broker): use assertQueue in RabbitMQ getTopicLag to avoid channel-closing 404 (EVO-1217)

fix(campaign-sender): review findings — pending-only hydration, dedupe, cache bound (EVO-1217)