Trigger

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

Wait for message in AMQP queue

Examples

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 test of schedule, this can avoid to overload the remote system with too many call. For most of trigger that depend on external system, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval value

maxDuration

• Type: string
• Dynamic: ❓
• Required: ❌
• Format: duration

The max duration waiting for new rows.

It's not an hard limit and is evaluated every second.

maxRecords

• Type: integer
• Dynamic: ❓
• Required: ❌

The max number of rows to fetch before stopping.

It's not an hard limit and is evaluated every second.

password

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker password

port

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker port

username

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker username

virtualHost

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker virtual host

Outputs

count

• Type: integer

Number of row consumed.

uri

• Type: string

File URI containing consumed message.

Definitions