Skip to main content

Consume

Consume — see the properties below.

This node is also exposed as an AI Agent tool.

This node has 1 input port and 1 output port.

Common Properties​

Every node shares these.

  • Name — the node's display name on the canvas.
  • Color — the node's colour on the canvas.
  • Delay Before (sec) — wait this long before the node runs.
  • Delay After (sec) — wait this long after the node runs.
  • Continue On Error — carry on instead of failing the flow. Defaults to false.
info

When Continue On Error is true the error is not raised at all, so a Catch node will not see it either.

Inputs​

PropertyFieldDescription
Client IDinClientIDClient ID from Connect node (optional if credentials provided)
Queue NameinQueueQueue name to consume from

Outputs​

PropertyFieldDescription
Delivery TagoutDeliveryTagDelivery tag for manual acknowledgment
ExchangeoutExchangeSource exchange name
Has MessageoutHasMessageWhether a message was retrieved from the queue
MessageoutMessageMessage body (parsed JSON or string)
Routing KeyoutRoutingKeyMessage routing key

Options​

PropertyFieldDescription
Auto AcknowledgeoptAutoAckAutomatically acknowledge message after receiving One of: true, false.
CredentialsoptCredentialsRabbitMQ connection credentials (optional if Client ID provided)
Parse JSONoptParseJSONParse message body as JSON if possible One of: true, false.

Requirements​

  • A Client ID from this package's Connect node, unless you set credentials directly on this node.
  • RabbitMQ Connection — Connection settings for RabbitMQ server
    • server — Host (text, required). RabbitMQ server hostname or IP address
    • port — Port (number, optional). RabbitMQ AMQP port (default: 5672)
    • username — Username (text, required). RabbitMQ username
    • password — Password (password, required). RabbitMQ password
    • database — Virtual Host (text, optional). RabbitMQ virtual host (default: /)

Store these in a Vault and reference the vault item from the node, rather than typing the secret into the property.

Publish

Elsewhere in the package: Connect · Disconnect · Declare Queue · Delete Queue · Purge Queue · Bind Queue · Declare Exchange · Delete Exchange · Toolkit

See also​