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
The queue to pull messages from.
Dynamic YES
Default STRING
Possible Values
STRINGJSON
Serializer / Deserializer used for the message.
Dynamic YES
Default Kestra
A client-generated consumer tag to establish context.
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