Consume messages from an AMQP queue.

Requires maxDuration or maxRecords.

yaml
type: "io.kestra.plugin.amqp.consume"

yaml
id: amqp_consume
namespace: company.team

tasks:
  - id: consume
    type: io.kestra.plugin.amqp.Consume
    url: amqp://guest:guest@localhost:5672/my_vhost
    queue: kestramqp.queue
    maxRecords: 1000

The queue to pull messages from.

Default STRING

Possible Values

STRINGJSON

Serializer / Deserializer used for the message.

Default Kestra

A client-generated consumer tag to establish context.

The broker host.

Format duration

The maximum duration to wait for new rows.

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

The maximum number of rows to fetch before stopping.

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

The broker password.

The broker port.

The broker username.

The broker virtual host.

Number of rows consumed.

Format uri

File URI containing consumed messages.