Send Queue Message
Sends a message to a queue. The message will be delivered to all workflows subscribed to the queue, triggering their execution with the message payload as input.
Inputs
| Name | Type | Required | Description |
|---|---|---|---|
| queueId | queue | Yes | Queue ID |
| schema | schema | No | Optional schema to validate and coerce message payload before sending |
| message | json | Yes | Message payload (any JSON value) |
Outputs
| Name | Type | Description |
|---|---|---|
| success | boolean | True if message was sent successfully |
| messageId | string | Unique identifier for the sent message |
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.
Receive Queue Message
Receives and extracts the message payload from a 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