Skip to main content

Publish

Publishes in RabbitMQ.

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)
Exchange NameinExchangeExchange name to publish to (leave empty to use queue)
MessageinMessageMessage body (string or JSON object)
Queue NameinQueueQueue name to publish to (leave empty to use exchange)
Routing KeyinRoutingKeyRouting key for exchange (required for direct/topic exchanges)

Outputs

PropertyFieldDescription
SuccessoutSuccessWhether the message was published successfully

Options

PropertyFieldDescription
Content TypeoptContentTypeMessage content type One of: application/json, text/plain, application/octet-stream.
CredentialsoptCredentialsRabbitMQ connection credentials (optional if Client ID provided)
Delivery ModeoptDeliveryModeMessage persistence mode One of: persistent, transient.
ExpirationoptExpirationMessage TTL in milliseconds (e.g. 60000 for 1 minute)
PriorityoptPriorityMessage priority (0-9)
Timeout (seconds)optTimeoutMaximum time to wait for publish confirmation

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.

Consume

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

See also