Publish

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

Dynamic YES

The exchange to publish the message to

Dynamic YES

The source of the data published.

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

Dynamic YES

The broker host.

Dynamic YES

The broker password.

Dynamic YES

The broker port.

Dynamic YES

The routing key

Dynamic YES

Default STRING

Possible Values

STRINGJSON

Serializer / Deserializer used for the message.

Dynamic YES

The broker username.

Dynamic YES

The broker virtual host.

Number of messages published.

​Publish

Publish