publish
Publish a message to an AMQP exchange.
publish
Publish a message to an AMQP exchange.
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
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
Properties
exchange*Requiredstring
The exchange to publish the message to
from*Requiredstringarray
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.
Definitions
io.kestra.plugin.amqp.models.Message
appIdstring
contentEncodingstring
contentTypestring
correlationIdstring
dataobject
deliveryModeinteger
expirationstring
Format
durationheadersobject
messageIdstring
priorityinteger
replyTostring
timestampstring
Format
date-timetypestring
userIdstring
host*Requiredstring
The broker host
passwordstring
The broker password
portstring
Default
5672The broker port
routingKeystring
The routing key
serdeTypestring
Default
STRINGPossible Values
STRINGJSONSerializer / Deserializer used for the message.
usernamestring
The broker username
virtualHoststring
Default
/The broker virtual host
Outputs
messagesCountinteger
Number of messages published
Metrics
published.recordscounter
Unit
recordsNumber of messages published to the AMQP exchange
