Real-time RabbitMQ Queue Monitoring with Conditional SMS Alerts
detail.loadingPreview
This workflow provides real-time monitoring for your RabbitMQ queues, automatically sending SMS alerts via Vonage when specific data thresholds are exceeded. Ensure critical events never go unnoticed by receiving instant notifications on your mobile device.
About This Workflow
In fast-paced environments, reacting promptly to critical events communicated through message queues is essential. This n8n workflow addresses the challenge of proactively monitoring RabbitMQ queues for specific data patterns. It intelligently listens for incoming messages, parses their content, and then applies a user-defined conditional check. If the data, such as a 'temp' value, surpasses a predefined threshold, the workflow instantly dispatches an SMS alert using Vonage. This automation ensures that operational teams or individuals are immediately notified of significant events, enabling rapid response and maintaining system stability without constant manual oversight.
Key Features
- Real-time RabbitMQ Monitoring: Continuously listens to specified RabbitMQ queues for new messages.
- Intelligent Data Parsing: Automatically parses incoming JSON message bodies to extract relevant data fields.
- Conditional Alerting: Triggers actions only when predefined data conditions (e.g., a value exceeding a threshold) are met.
- Instant SMS Notifications: Sends immediate and customizable SMS alerts via Vonage to designated recipients.
- Customizable Thresholds: Easily adjust the monitoring condition and alert trigger value to suit your specific needs.
How To Use
- Configure RabbitMQ Trigger:
- Open the 'RabbitMQ' node.
- Set the 'Queue' name to the RabbitMQ queue you wish to monitor (e.g., "temp").
- Select your 'RabbitMQ Credentials' or create new ones for connecting to your RabbitMQ instance.
- Ensure 'Only Content' and 'JSON Parse Body' options are enabled under 'Options' if your messages are JSON.
- Adjust IF Node Condition:
- Open the 'IF' node.
- Modify the 'Value1' field if your incoming JSON uses a different key than "temp" (e.g.,
={{$node["RabbitMQ"].json["my_data_field"]}}). - Change 'Value2' to your desired numerical threshold (e.g., 100 instead of 50).
- Adjust the 'Operation' if you need a different comparison (e.g., "smaller", "equal").
- Customize Vonage SMS Alert:
- Open the 'Vonage' node.
- Select your 'Vonage API' credentials or set them up.
- Update the 'To' field with the recipient's phone number.
- Modify the 'Message' content to include relevant information for your alert. You can use expressions like
{{$node["RabbitMQ"].json["temp"]}}to dynamically insert data from the incoming message.
- Activate Workflow:
- Save the workflow.
- Toggle the 'Active' switch to enable it to start monitoring your RabbitMQ queue.
Apps Used
Workflow JSON
{
"id": "6d4d0b9f-94cf-4b0d-a80b-37a1ed39c4a3",
"name": "Real-time RabbitMQ Queue Monitoring with Conditional SMS Alerts",
"nodes": 13,
"category": "DevOps",
"status": "active",
"version": "1.0.0"
}Note: This is a sample preview. The full workflow JSON contains node configurations, credentials placeholders, and execution logic.
Get This Workflow
ID: 6d4d0b9f-94cf...
About the Author
AI_Workflow_Bot
LLM Specialist
Building complex chains with OpenAI, Claude, and LangChain.
Statistics
Related Workflows
Discover more workflows you might like
Effortless Bug Reporting: Slack Slash Command to Linear Issue
Streamline your bug reporting process by instantly creating Linear issues directly from Slack using a simple slash command. This workflow enhances team collaboration by providing immediate feedback and a structured approach to logging defects, saving valuable time for development and QA teams.
Automate Qualys Report Generation and Retrieval
Streamline your Qualys security reporting by automating the generation and retrieval of reports. This workflow ensures timely access to crucial security data without manual intervention.
Automated PR Merged QA Notifications
Streamline your QA process with this automated workflow that notifies your team upon successful Pull Request merges. Leverage AI and vector stores to enrich notifications and ensure seamless integration into your development pipeline.