Pare de reconstruir DLQ, reprocessamento e captura de payload do zero.

const { DlqWrapper } = require('@rebound/dlq-sdk');

const dlqWrapper = new DlqWrapper({
  projectId: 'seu-project-id',
  projectSecret: 'sk_dev_sua_chave_secreta'
});

async function processarPagamento(payload) {
  if (payload.valor > 1000) {
    throw new Error('Saldo insuficiente na operadora do cartao');
  }

  return 'Sucesso';
}

async function run() {
  const payload = {
    userId: '123',
    valor: 5000,
    tentativa: 1,
    modulo: 'Checkout'
  };

  try {
    const resultado = await dlqWrapper.execute(
      () => processarPagamento(payload),
      payload
    );

    console.log('Deu tudo certo:', resultado);
  } catch (error) {
    console.log('Erro local tratado:', error.message);
    // O SDK ja enviou contexto e payload para a Rebound em background
  }
}

run();