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