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
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtualHost: /my_vhost
    queue: kestramqp.queue
    maxRecords: 1000

Properties

host*string

queue*string

serdeType*string

DefaultSTRING

Possible Values

STRINGJSON

consumerTagstring

DefaultKestra

maxDurationstring

Formatduration

maxRecordsintegerstring

passwordstring

portstring

Default5672

usernamestring

virtualHoststring

Default/

Outputs

countinteger

uristring

Formaturi

Metrics

consumed.recordscounter