AMQP Trigger Manual ACK

I’m developing a workflow in n8n that uses the AMQP Trigger node to receive messages from an AMQ broker, do some process, and then send the result to an API endpoint.

What I need is for the AMQP Trigger node to only send an ACK (ACCEPTED) to the broker if the workflow executes successfully until the end. Otherwise, the node should send a NACK (or RELEASED/REJECT/MODIFIED) so that the broker does not discard the message and can redeliver it.

The problem is that the AMQP Trigger node does not have a “Manual Acknowledgement” option or something like (he RabbitMQ Trigger node does). Also, the RabbitMQ Trigger node cannot communicate with my broker.

How can I work around this situation?

Hey! This sounds like a valid thing to direct towards Feature Requests.

  1. Error workflow and re-submit to queue
  • Set up an Error Trigger node in a separate workflow
  • Configure the main workflow’s error settings to call the error workflow
  • Use the AMQP Sender node in the error workflow to republish failed messages to a retry queue
  1. HTTP/API approach
  • Use Schedule Trigger to periodically check message queues
  • Implement message retrieval using HTTP Request nodes to broker management APIs
  • Process messages with explicit acknowledgment control through API calls

Hope this helps!

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.