Messaging-Queues
Messaging & Queue Integrations – Kafka, AMQP, AWS SQS, AWS SNS, Redis
Summary (SEO Meta Description):
Learn how to use Messaging & Queue integrations in WeHub, including Kafka, AMQP, AWS SQS, AWS SNS, and Redis.
Configure message brokers and event-driven triggers to publish, subscribe, and process data in real time.
Overview
Messaging & Queue plugins in WeHub connect workflows to event-driven systems like Apache Kafka, RabbitMQ (AMQP), Amazon SQS, Amazon SNS, and Redis.
These integrations make it easy to publish messages, subscribe to queues, and trigger workflows when new events occur.
Typical Use Cases:
- Kafka Integration: Stream events from Kafka topics into workflows.
- AMQP Integration: Connect to RabbitMQ or other AMQP-compatible brokers.
- AWS SQS Integration: Process queued messages reliably at scale.
- AWS SNS Integration: Subscribe to topics and handle notifications.
- Redis Integration: Use Redis as a lightweight queue or pub/sub system.
Available Plugins
| Plugin | Description |
|---|---|
| Kafka Plugin | Subscribe to topics or publish events to Kafka. |
| AMQP Plugin | Publish and subscribe to AMQP queues like RabbitMQ. |
| AWS SNS Plugin | Subscribe to SNS topics and receive notifications. |
| AWS SQS Plugin | Subscribe to SQS queues and process queued messages. |
| Redis Plugin | Use Redis for caching, pub/sub, or queue management. |
FAQ
Q: Can I use Kafka or AMQP as both a Trigger and Processor in WeHub?
A: Yes. Kafka and AMQP integrations support dual categorization, meaning they can act as Triggers (🔵 Blue) or Processors (🟠 Orange) depending on the selected action.
Q: What’s the difference between AWS SQS and SNS in workflows?
A: Use SNS for pub/sub style notifications (fan-out), and SQS for queue-based message processing (point-to-point).
Keywords: WeHub Kafka Integration, WeHub AMQP Plugin, AWS SQS Workflow Automation, AWS SNS Integration, Redis Pub/Sub Plugin