n8n-nodes-sentinelmq

🛡 SentinelMQ - Anti-Flood Control Node for n8n

SentinelMQ replaces FloodGuard as the next-generation anti-flood system for n8n workflows. It provides advanced message flooding protection, ensuring stability and security for high-volume messaging pipelines.

SentinelMQ detects and prevents abuse through intelligent monitoring of message rates, temporary blocking, and dynamic aggregation. It validates messages and sends consolidated data to dynamic HTTP webhooks with risk levels.

Functionalities

Flood Detection:

• Monitors message rate per sender (configurable, default: 3 msg/second).
• Sliding window of 1 second for temporal analysis.
• Automatic temporary blocking upon flood detection (configurable, default: 60 minutes).
• Logs blocking events with remaining time.

Probing Detection (Proposed):

• Detects multiple spaced bursts over time.
• Burst counter per sender.
• Extended blocking (2x duration) for probing patterns.
• Identifies attempts to discover system limits.

Circuit Breaker (Proposed):

• States: CLOSED, OPEN, HALF_OPEN.
• Automatic transitions based on cumulative failures.
• Trial period before full service restoration.
• State reset after correct behavior.

Message Aggregation:

• Individual buffer per client (configurable limit: 1000 messages).
• Grouped sending after a time interval (7 seconds).
• Forced sending upon reaching threshold (100 messages).
• Concatenation with line breaks.

Validation and Security:

• Full UTF-8 validation of messages.
• Message length limit (4096 characters).
• Automatic JSON escaping of special characters.
• Discards oldest messages if buffer is full.

Dynamic Webhooks:

• Configurable URL per client.
• HTTP POST with structured JSON.
• Risk levels: normal, high (flood), probing (proposed).

State Management:

• Message timestamps for temporal analysis.
• Per-sender statistics (timestamps, blocking state).
• Thread-safe using mutex.

Error Handling:

• Detailed error logging (invalid format, exceeded limits).
• Handles HTTP connection failures.

Operational Features:

• Concurrent processing of multiple clients.
• Automatic cleanup on startup.
• Temporal decoupling between reception and sending.

Installation

npm install n8n-nodes-sentinelmq

Once installed, you can add the node directly from your n8n editor.

** ⚠ Important: This node requires the backend processing service to be deployed and available. ** Deployment instructions for the backend are provided privately during provisioning.

Delivery Model

SentinelMQ operates under a controlled distribution model:

• Backend processing binaries are provided per-client, per-environment.
• Each delivery includes custom build configuration tailored to your system.
• The backend engine remains fully managed by your system administrator.
• For deployment inquiries or commercial licenses, please contact the author directly.

License

Custom Licensing

Author

SentinelMQ maintained by DevitWorks