Consume
yaml
type: "io.kestra.plugin.amqp.consume"Examples
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
Properties
host *Requiredstring
queue *Requiredstring
consumerTag string
Default
KestramaxDuration string
Format
durationmaxRecords integerstring
password string
port string
Default
5672serdeType string
Default
STRING Possible Values
STRINGJSONusername string
virtualHost string
Default
/Outputs
count integer
uri string
Format
uri