AMQPAMQP
AMQPCertified

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Provide host/port/credentials/virtual host values for each connection, and set stop conditions such as maxDuration or maxRecords when consuming.

tasks

Consume

Consume messages from an AMQP queue.

io.kestra.plugin.amqp.Consume
CreateQueue

Create an AMQP queue.

io.kestra.plugin.amqp.CreateQueue
DeclareExchange

Create an AMQP exchange.

io.kestra.plugin.amqp.DeclareExchange
Publish

Publish a message to an AMQP exchange.

io.kestra.plugin.amqp.Publish
QueueBind

Bind a queue to an AMQP exchange.

io.kestra.plugin.amqp.QueueBind

triggers

RealtimeTrigger

Consume AMQP messages in real-time, and create one execution per message.

io.kestra.plugin.amqp.RealtimeTrigger
Trigger

Consume AMQP messages periodically, and create one execution per batch.

io.kestra.plugin.amqp.Trigger

Create automations with Amqp Plugins

Read a CSV file and load each row into RabbitMQ
Data

More Plugins in this Category

Resend
Resend

Tasks that manage domains and send email via the Resend API.

Messaging

2 Tasks

MQTT
MQTT

Tasks that publish, subscribe, and trigger workflows with MQTT.

Messaging

4 Tasks

Azure
Azure

Leverage Microsoft Azure services within Kestra data workflows.

CloudMessagingStorageBatchTool

37 Tasks

2 Blueprints

OVERVIEW
Versions
1.1.0
Latest
October 31, 2025 Release Notes Min. Compatible Kestra Version: 1.0.0
Previous Versions
1.0.2October 31, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.1October 27, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.0September 8, 2025 Min. Compatible Kestra Version: [1.0,)
0.24.0August 5, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc1-SNAPSHOTJuly 31, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc0-SNAPSHOTJuly 29, 2025 Min. Compatible Kestra Version: [0.23,)
0.23.0-rc5-SNAPSHOTJune 16, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc4-SNAPSHOTJune 12, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc3-SNAPSHOTJune 10, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc2-SNAPSHOTJune 9, 2025 Min. Compatible Kestra Version: [0.20,)
0.23.0-rc1-SNAPSHOTJune 4, 2025 Min. Compatible Kestra Version: [0.20,)
0.23.0-rc0-SNAPSHOTJune 3, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0April 1, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc4-SNAPSHOTMarch 31, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc2-SNAPSHOTMarch 28, 2025 Min. Compatible Kestra Version: [0.20,)
0.22.0-rc1-SNAPSHOTMarch 25, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0February 4, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc2-SNAPSHOTFebruary 3, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc1-SNAPSHOTJanuary 31, 2025 Min. Compatible Kestra Version: [0.20,)
0.21.0-rc0-SNAPSHOTJanuary 29, 2025 Min. Compatible Kestra Version: [0.20,)
0.20.0December 3, 2024 Min. Compatible Kestra Version: [0.20,)
0.19.0October 1, 2024 Min. Compatible Kestra Version: [0.18,)
0.18.0August 6, 2024 Min. Compatible Kestra Version: [0.18,)
0.17.1June 27, 2024 Min. Compatible Kestra Version: [0.17,)
0.17.0June 4, 2024 Min. Compatible Kestra Version: [0.17,)
0.16.0April 11, 2024 Min. Compatible Kestra Version: [0.16,)
0.15.0February 29, 2024 Min. Compatible Kestra Version: [0.15,)
0.14.0January 20, 2024 Min. Compatible Kestra Version: [0.14,)
0.13.0November 16, 2023 Min. Compatible Kestra Version: [0.13,)

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Messaging
Links & Resources
GitHub