Consume messages from an AMQP queue.
Requires maxDuration or maxRecords.
type: "io.kestra.plugin.amqp.consume"id: amqp_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.amqp.Consume
host: localhost
port: 5672
username: guest
password: guest
virtualHost: /my_vhost
queue: kestramqp.queue
maxRecords: 1000
The broker host
The queue to pull messages from
STRINGSTRINGJSONSerialization format
Defines how message payloads are serialized or deserialized. Use STRING for plain text or JSON for structured data.
KestraA client-generated consumer tag to establish context
durationMaximum duration
The maximum duration the consumer will run before stopping. This is a soft limit evaluated approximately every 100 milliseconds, so the actual duration may slightly exceed this value.
Maximum number of records
The maximum number of messages to consume before stopping. This is a soft limit evaluated after each message.
The broker password
5672The broker port
The broker username
/The broker virtual host
Number of rows consumed
uriFile URI containing consumed messages