Webhook and RabbitMQ integration

Publish Subscribe Example - Webhook to RabbitMQ, RabbitMQ to GMAIL How it works This workflow demonstrates a resilient publish/subscribe automation pattern using n8n, RabbitMQ, JSON Schema validation, and Gmail. It contains two flows in the same workflow: A publisher flow receives client onboarding JSON through a webhook. The payload is validated against a JSON Schema. If valid, the workflow publishes the event to RabbitMQ. A subscriber flow listens to the RabbitMQ queue. The subscriber validates the received event again. If the message is valid, it prepares and sends a Gmail notification. Invalid messages and processing failures are routed to a dead-letter/error queue. This template is useful for client onboarding, accounting intake, document processing, form submissions, internal notifications, and event-driven workflow automation. Set up steps Create or connect a RabbitMQ instance. Create the following RabbitMQ resources: Exchange: client.onboarding.exchange Exchange type: topic Main queue: client.onboarding.queue Routing key: client.onboarding.received Dead letter/error queue: client.onboarding.dlq In n8n, configure your RabbitMQ credentials. Replace the RabbitMQ credential placeholder with your own RabbitMQ credential. Replace the JSON Schema Validator placeholder nodes with your preferred JSON Schema validation node or validation service. Configure the Gmail credential. Replace the Gmail placeholder node with the Gmail Send Email node. Update the recipient email address in the “Prepare Gmail Email” node. Test the publisher webhook with a sample client onboarding JSON payload. Confirm the message is published to RabbitMQ and then consumed by the subscriber flow. Confirm Gmail receives the formatted notification email. Required credentials RabbitMQ credentials Gmail OAuth2 credentials Optional JSON Schema validator community node or external validation service Example input JSON { "clientId": "C1001", "clientName": "John Smith", "email": "[email protected]", "serviceType": "Individual Tax Return", "taxYear": 2025, "documents": [ { "documentType": "Photo ID", "fileName": "john-smith-passport.pdf" }, { "documentType": "PAYG Summary", "fileName": "john-smith-payg-summary.pdf" } ] } Resilience and Error Handling This template includes: Validation before publish Validation after subscribe Correlation ID Schema version Dead-letter queue Email failure branch Invalid message branch RabbitMQ publish failure branch Invalid or failed messages are routed to client.onboarding.dlq.