Trigger

yaml

type: "io.kestra.plugin.amqp.Trigger"

Wait for message in AMQP queue.

Examples

yaml

id: "trigger"
type: "io.kestra.plugin.amqp.Trigger"
url: amqp://guest:guest@localhost:5672/my_vhost
maxRecords: 2
queue: amqpTrigger.queue

Properties

`consumerTag`

Type: string
Dynamic: ❓
Required: ✔️
Default: Kestra

A client-generated consumer tag to establish context.

`queue`

Type: string
Dynamic: ✔️
Required: ✔️

The queue to pull messages from.

`serdeType`

Type: string
Dynamic: ❓
Required: ✔️
Default: STRING
Possible Values:
- STRING
- JSON

Serializer / Deserializer used for the message.

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of conditions in order to limit the flow trigger.

`host`

Type: string
Dynamic: ✔️
Required: ❌

The broker host.

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
Format: duration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.