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
host: localhost
port: 5672
username: guest
password: guest
virtualHost: /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
Structured data items, either as a map, a list of map, a URI, or a JSON string.
Structured data items can be defined in the following ways:
- A single item as a map (a document).
- A list of items as a list of maps (a list of documents).
- A URI, supported schemes are
kestrafor internal storage files,filefor host local files, andnsfilefor namespace files. - A JSON String that will then be serialized either as a single item or a list of items.
The broker host
The broker password
Default
5672The broker port
The routing key
Default
STRING Possible Values
STRINGJSONSerializer / Deserializer used for the message.
The broker username
Default
/The broker virtual host
Number of messages published
Format
duration Format
date-time