Publish a message to an AMQP exchange.

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

yaml
id: amqp_publish
namespace: company.team

tasks:
  - id: publish
    type: io.kestra.plugin.amqp.Publish
    url: amqp://guest:guest@localhost:5672/my_vhost
    exchange: kestramqp.exchange
    from:
      - data: value-1
        headers:
            testHeader: KestraTest
        timestamp: '2023-01-09T08:46:33.103130753Z'
      - data: value-2
        timestamp: '2023-01-09T08:46:33.115456977Z'
        appId: unit-kestra

The exchange to publish the message to

The source of the data published.

It can be a Kestra's internal storage URI or a list.

The broker host.

The broker password.

The broker port.

The routing key

Default STRING

Possible Values

STRINGJSON

Serializer / Deserializer used for the message.

The broker username.

The broker virtual host.

Number of messages published.