Publish
yaml
type: "io.kestra.plugin.amqp.Publish"
Publish a message to an AMQP exchange
Examples
yaml
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:stringarray
- Dynamic: ✔️
- Required: ✔️
The source of the data published
Can be an 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
Number of message published