Skip to main content

Acknowledging

You must call notification.ack() to confirm processing:
connection.on('rule.violated', 'order_placed', async (notification) => {
  try {
    await processViolation(notification);
    notification.ack();  // ACK on success
  } catch (error) {
    // Don't ACK - notification redelivered after 30s (max 3 attempts)
  }
});

Retry Behavior

AttemptDelayAction
10sInitial delivery
230sFirst retry (if no ACK)
330sSecond retry (if no ACK)
Failed-Moved to Dead Letter Queue

Next Steps