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 *Requiredstring
The exchange to publish the message to
from *RequiredstringarrayMessage
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.
host *Requiredstring
The broker host
password string
The broker password
port string
Default
5672The broker port
routingKey string
The routing key
serdeType string
Default
STRING Possible Values
STRINGJSONSerializer / Deserializer used for the message.
username string
The broker username
virtualHost string
Default
/The broker virtual host
Outputs
messagesCount integer
Number of messages published
Definitions
io.kestra.plugin.amqp.models.Message
appId string
contentEncoding string
contentType string
correlationId string
data object
deliveryMode integer
expiration string
Format
durationheaders object
messageId string
priority integer
replyTo string
timestamp string
Format
date-time