Handling Notifications

threadify.on('rule.violated', 'order_placed', async (notification) => {
  try {
    await processViolation(notification);
    notification.ack();  // ACK on success
  } catch (error) {
    // Don't ACK on failure; allow configured redelivery
  }
});

err := conn.Subscribe(ctx, "rule.violated", "order_placed", func(n *threadify.Notification) {
    err := processViolation(n)
    if err != nil {
        // Don't ACK on failure; allow configured redelivery
        return
    }
    n.Ack() // ACK on success
})
if err != nil {
    log.Fatal(err)
}

def on_violation(notification):
    try:
        process_violation(notification)
        notification.ack()  # ACK on success
    except Exception:
        # Don't ACK on failure; allow configured redelivery
        pass

connection.subscribe("rule.violated", "order_placed", on_violation)