Publish

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 *string

from *stringarray

Definitions

io.kestra.plugin.amqp.models.Message

appIdstring

contentEncodingstring

contentTypestring

correlationIdstring

dataobject

deliveryModeinteger

expirationstring

Formatduration

headersobject

messageIdstring

priorityinteger

replyTostring

timestampstring

Formatdate-time

typestring

userIdstring

host *string

password string

port string

Default5672

routingKey string

serdeType string

DefaultSTRING

Possible Values

STRINGJSON

username string

virtualHost string

Default/

Outputs

messagesCount integer

Metrics

published.records counter

Unitrecords

Read a CSV file and load each row into RabbitMQ

Apache Pulsar

Tasks that publish, consume, and trigger workflows with Apache Pulsar.

Messaging

AWS

AWS plugin for Kestra

AlertingCloudMessagingStorageDatabaseScriptToolTransformation

NATS

Tasks that publish, subscribe, and work with NATS messaging.

Messaging

Publish

Create automations with Amqp Publish

Read a CSV file and load each row into RabbitMQ

More Plugins in this Category

Apache Pulsar

AWS

NATS

1.1.1