Publish

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

Publish a message to an AMQP exchange.

Examples

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

• Type: string
• Dynamic: ✔️
• Required: ✔️

The exchange to publish the message to

from

• Type:
  • string
  • array
• Dynamic: ✔️
• Required: ✔️

The source of the data published.

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

host

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker host.

password

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker password.

port

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker port.

routingKey

• Type: string
• Dynamic: ✔️
• Required: ❌

The routing key

serdeType

• Type: string
• Dynamic: ❓
• Required: ❌
• Default: STRING
• Possible Values:
  • STRING
  • JSON

Serializer / Deserializer used for the message.

username

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker username.

virtualHost

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker virtual host.

Outputs

messagesCount

• Type: integer
• Required: ❌

Number of messages published.