Consume a message in real-time from an AMQP queue and create one execution per message.
If you would like to consume multiple messages processed within a given time frame and process them in batch, you can use the io.kestra.plugin.amqp.Trigger instead.
yaml
type: "io.kestra.plugin.amqp.RealtimeTrigger"Consume a message from a AMQP queue in real-time.
yaml
id: amqp
namespace: company.team
tasks:
- id: log
type: io.kestra.plugin.core.log.Log
message: "{{ trigger.data }}"
triggers:
- id: realtime_trigger
type: io.kestra.plugin.amqp.RealtimeTrigger
url: amqp://guest:guest@localhost:5672/my_vhost
queue: amqpTrigger.queue
Dynamic YES
Default Kestra
A client-generated consumer tag to establish context.
Dynamic YES
The queue to pull messages from.
Dynamic NO
Default STRING
Possible Values
STRINGJSON
Serializer / Deserializer used for the message.
Dynamic YES
The broker host.
Dynamic YES
The broker password.
Dynamic YES
The broker port.
SubType string
Dynamic NO
List of execution states after which a trigger should be stopped (a.k.a. disabled).
Dynamic YES
The broker username.
Dynamic YES
The broker virtual host.
Format duration
Format date-time