feat(infra): PGMQ workers — processAsync CF<ProcessOutcome>, no .join#1305

Merged

zbnerd merged 13 commits into

feature/pgmq-process-async

Jun 18, 2026

Commits on Jun 18, 2026

docs: CF chain blocking audit (2026-06-18)
zbnerd
committed
feat(infra): ProcessOutcome sealed class — Ack | Nack | DeadLetter
zbnerd
committed
feat(infra): PgmqWorker.processAsync — open + default wraps process()
zbnerd
committed
feat(infra): ExternalApiWorker — processAsync, no .join, no runBlocking
zbnerd
committed
feat(infra): CalculationWorker — processAsync, no .join
zbnerd
committed
feat(infra): CalculationRequestedWorker — processAsync entry
zbnerd
committed
feat(infra): CalculationCompletedWorker — processAsync entry
zbnerd
committed
feat(infra): DonationWorker — processAsync entry
zbnerd
committed
feat(infra): NexonFanOutWorker — processAsync, 429 retry via visibilityReset
zbnerd
committed
feat(infra): ResultReadyProjectionWorker — no .join, no runBlocking
zbnerd
committed
test(infra): CI grep gate for blocking primitives in pgmq/worker
zbnerd
committed
feat(infra): PgmqWorker.processSequentialBatch — no runBlocking, CF allOf
zbnerd
committed
test(infra): tighten CI grep gate — PgmqWorker.kt no longer allowlisted for runBlocking
zbnerd
committed