DeclareExchange

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

Create an exchange.

Examples

id: amqp_declare_exchange
namespace: company.team

tasks:
  - 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

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

durability

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

Specify 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

Specify 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
• Required: ❌

The exchange name.