🚀 New! Kestra raises $3 million to grow Learn more

PLUGINSPLUGIN-AMQPTASKSIO.KESTRA.PLUGIN.AMQP.DECLAREEXCHANGE

​Declare​Exchange

DeclareExchange DeclareExchange

yaml
type: "io.kestra.plugin.amqp.DeclareExchange"

Create an Exchange

Examples

yaml
id: "declare_exchange"
type: "io.kestra.plugin.amqp.DeclareExchange"
url: amqp://guest:guest@localhost:5672/my_vhost
name: kestramqp.exchange

Properties

name

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️

The name of the exchange

args

  • Type: object
  • Dynamic: ❓
  • Required: ❌

Other properties (construction arguments) for the exchange

autoDelete

  • Type: boolean
  • Dynamic: ❓
  • Required: ❌
  • Default: false

True if the server should delete the exchange when it is no longer in use

durability

  • Type: boolean
  • Dynamic: ❓
  • Required: ❌
  • Default: true

True if we are declaring a durable exchange (the exchange will survive a server restart)

exchangeType

  • Type: string
  • Dynamic: ❓
  • Required: ❌
  • Default: DIRECT
  • Possible Values:
    • DIRECT
    • FANOUT
    • TOPIC
    • HEADERS

The exchange type

host

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

The broker host

internal

  • Type: boolean
  • Dynamic: ❓
  • Required: ❌
  • Default: false

True if the exchange is internal, i.e. can't be directly published to by a client.

password

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

The broker password

port

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

The broker port

username

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

The broker username

virtualHost

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

The broker virtual host

Outputs

exchange

  • Type: string

Exchange name