RabbitMQ / AMQP

Message broker: publish and consume messages on queues and exchanges over AMQP

Signs in with: Connection details
Runs on: Cloud or On-Prem Worker
Operations: 12
Ready-made triggers: 0

Connect RabbitMQ / AMQP

In Neblex open Connect › Connections and click New Connection.
Search for RabbitMQ / AMQP and give the connection a clear name.
Fill in the fields. Secret values are encrypted and never shown again.
Click Test, then Create Connection.

If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.

Field	What to enter
Connection modeRequired
HostRequired
PortOptional	Example: `5671`
Virtual hostOptional
UsernameOptional
PasswordOptionalSecret
Use TLSOptional	Turning this off sends traffic and credentials without transport encryption.
Connection stringRequiredSecret	Paste an amqp:// or amqps:// connection string.

Use it in a flow

Open a flow, open the node library and search for RabbitMQ / AMQP.
Drag it onto the canvas and choose an Operation and your connection.
Map the operation's fields from earlier steps, or click Map with Matt.
Use Test this step to see what it returns, then save.

To start a flow from RabbitMQ / AMQP without a ready-made trigger: a Live stream trigger with RabbitMQ / AMQP as the stream source starts a run for each message as it arrives (see Streaming triggers).

Operations

12 operations in 4 groups. Each one is a step you can add to a flow.

Connection1

Test the connectionping Complete an AMQP 0-9-1 connection and channel handshake.

Exchange4

Bind an exchange`bind_exchange`		Bind an exchange using the exact AMQP 0-9-1 method.
Declare an exchange`declare_exchange`		Declare an exchange using the exact AMQP 0-9-1 method.
Delete an exchange`delete_exchange`		Delete an exchange using the exact AMQP 0-9-1 method.
Unbind an exchange`unbind_exchange`		Unbind an exchange using the exact AMQP 0-9-1 method.

Message2

Get a message`get`		Pull one message and settle it on the same channel.
Publish a message`publish`		Publish byte-exact content with publisher confirms and mandatory routing by default.

Queue5

Bind a queue`bind_queue`		Bind a queue using the exact AMQP 0-9-1 method.
Declare a queue`declare_queue`		Declare a queue using the exact AMQP 0-9-1 method.
Delete a queue`delete_queue`		Delete a queue using the exact AMQP 0-9-1 method.
Purge a queue`purge_queue`		Purge a queue using the exact AMQP 0-9-1 method.
Unbind a queue`unbind_queue`		Unbind a queue using the exact AMQP 0-9-1 method.