Consume
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
STRINGJSONSerializer / Deserializer used for the message.
Default
KestraA client-generated consumer tag to establish context.
The broker host.
Format
durationThe 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
uriFile URI containing consumed messages.