Receive Queue Message
This node extracts the message payload from a queue-triggered workflow, providing access to the data sent when the message was published.
Inputs
| Name | Type | Required | Description |
|---|---|---|---|
| queueId | queue | Yes | The queue ID to listen to for messages. |
| schema | schema | No | Optional schema to validate and coerce the received message payload. |
Outputs
| Name | Type | Description |
|---|---|---|
| payload | json | The queue message payload |
| queueId | string | The ID of the queue this message came from |
| timestamp | number | The timestamp when the message was published |
Related Nodes in Developer Tools
JavaScript
Executes JavaScript in a sandboxed V8 isolate. Inputs are bound as `args` and console output is captured to stdout/stderr.
HTTP Request
Receives an HTTP request and returns the response synchronously.
HTTP Webhook
Receives an HTTP webhook and executes the workflow asynchronously.
Fetch
Fetch data from a URL using the Fetch API.
Database Query
Executes a SELECT query on a database and returns the results.
Database Execute
Executes INSERT, UPDATE, or DELETE operations on a database.
Conditional Fork
Splits the workflow into two branches based on a boolean condition. The 'true' output is taken if the condition is true, 'false' if false.
Conditional Join
Joins two mutually exclusive branches ('true' and 'false') into a single flow. Emits the value from the active branch. Errors if both or neither are provided.
Send Queue Message
Sends a single message to a message queue.
Aggregate Items
Collects multiple values into a repeated output array
Extract Item
Extracts a single item from a repeated input at the specified index