FlowDSL Node Catalog
RabbitMQ Consume
Subscribe to a queue. Emits one packet per delivered message.
Overview
| Property | Value |
|---|---|
| Node ID | rabbitmq/consume |
| Kind | source |
| Module | rabbitmq-flowdsl |
| Repo | go-module-rabbitmq |
| Handler | github.com/redelay/go-module-rabbitmq/flowdsl.Consume |
| Icon | lucide:inbox |
| Color | #f97316 |
| Tags | rabbitmq, amqp, consumer |
Outputs
message— (no description)
Settings
| Property | Type | Required | Default | UI Group | Description |
|---|---|---|---|---|---|
autoAck | boolean | — | false | Delivery | |
consumerTag | string | — | — | Delivery | |
queue | string | yes | — | Source |
Example
yaml
# Use this node in a flow:
nodes:
- id: my_step
name: My Step
kind: source
action_ref: rabbitmq/consume
config:
autoAck: false
consumerTag: "value"
queue: "value"