Publish

Publish a message to an AMQP exchange.

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

Examples

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

Properties

exchange *string

The exchange to publish the message to

from *stringarray

The source of the data published.

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

host *string

The broker host.

password string

The broker password.

port string

Default 5672

The broker port.

routingKey string

The routing key

serdeType string

Default STRING

Possible Values

STRINGJSON

Serializer / Deserializer used for the message.

username string

The broker username.

virtualHost string

Default /

The broker virtual host.

Outputs

messagesCount integer

Number of messages published.

​Publish

Publish