handleNotificationDLQ

SCHEDULED

Processa mensagens da Dead Letter Queue (notification.dlq): - Analisa lastError, classifica causa (validation/permanent/provider/transient). - Permite reprocessar com segurança (respeitando idempotencyKey) para fila original ou manter em DLQ. - Pode notificar admin/observabilidade quando volume exceder limiar. Retry/Backoff: - Tentativas: 3. - Backoff exponencial: baseDelayMs=5000, fator=2, maxDelayMs=60000. Timeout: - 30s. Idempotência: - Reprocessamento é sempre condicionado à deduplicação (idempotencyKey) e a um requeueKey para não reenfileirar infinitamente a mesma mensagem.

System: Notification Service
Type: SCHEDULED
Created: 18/02/2026, 22:10
Updated: 18/02/2026, 22:10

Config

queue: "notification.dlq"

backoff:

type: "exponential"

factor: 2

jitter: 0.2

maxDelayMs: 60000

baseDelayMs: 5000

timeoutMs: 30000

concurrency: 5

maxAttempts: 3

Input Schema

type: "object"

required:

0"correlationId"

1"dlqMessageId"

2"originalQueue"

3"originalPayload"

4"lastError"

5"receivedAt"

6"action"

properties:

action:

lastError:

receivedAt:

requeueKey:

dlqMessageId:

correlationId:

originalQueue:

originalPayload:

Outputs (2)

errorERROR

Resposta de erro

type: "object"

properties: {}

successSUCCESS

Resposta de sucesso

type: "object"

required:

0"dlqMessageId"

1"handled"

2"result"

3"handledAt"

properties:

result:

handled:

handledAt:

dlqMessageId:

requeuedJobId: