AMQP Message Sender Service

This workflow sends messages to an AMQP queue via a webhook. Key nodes include Webhook (receives POST requests), Input Validation (sanitizes message and queue name), Check Input Valid (verifies inputs), Prepare Message (formats message with timestamp), AMQP Sender (publishes to queue), Check Send Success (confirms delivery), Process Send Result (summarizes output), Success Response (returns JSON), and error responses (Invalid Input, AMQP Error, Processing Error). It uses the AMQP protocol (e.g., RabbitMQ). Setup Requirements Install n8n from n8n.io or sign up at cloud.n8n.io. Import the JSON into n8n’s workflow editor. Set up an AMQP server (e.g., RabbitMQ) locally or via a cloud provider like CloudAMQP. Obtain AMQP credentials (host, port, username, password) from your AMQP management interface or provider. In n8n, configure amqp credentials under amqp-credentials. Configure the Webhook node by copying its URL (/amqp-send). Set allowedOrigins (e.g., 'https://your-domain.com') for security. The workflow expects a JSON payload with 'message', 'queueName', 'priority', and optional 'headers'. Handle errors like empty message or queue name (400: Invalid input) or connection failures (502: AMQP message sending failed). Secure credentials and webhook URL. Testing and Deployment Import the JSON into n8n and activate the workflow. Ensure the AMQP server is running and credentials are configured. Test the Webhook with a POST request (e.g., curl -X POST [webhook-url] -d '{"message": "Test", "queueName": "testQueue"}' -H 'Content-Type: application/json'). Verify AMQP Sender publishes the message, Process Send Result summarizes details, and Success Response returns JSON with message_id and queue_name. Test error cases: send an empty message (400: Invalid input), invalid queue name (400: Invalid input), or incorrect credentials (502: AMQP message sending failed). Check n8n and AMQP logs for errors. Integrate the webhook URL into your application, ensure AMQP server accessibility, activate the workflow, and deploy for message sending. Monitor AMQP connection stability and queue status.