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