RealtimeTrigger

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.

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

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

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

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

​Realtime​Trigger

RealtimeTrigger