DeclareExchange
Create an AMQP exchange.
yaml
type: "io.kestra.plugin.amqp.DeclareExchange"Examples
yaml
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
host *Requiredstring
The broker host
name *Requiredstring
The name of the exchange
args object
Other properties (construction arguments) for the exchange
autoDelete booleanstring
Default
falseSpecifies if the server should delete the exchange when it is no longer in use
durability booleanstring
Default
trueSpecifies if declaring a durable exchange (the exchange will survive a server restart)
exchangeType string
Default
DIRECT Possible Values
DIRECTFANOUTTOPICHEADERSThe exchange type
internal booleanstring
Default
falseSpecifies if the exchange is internal, i.e., can't be directly published to by a client
password string
The broker password
port string
Default
5672The broker port
username string
The broker username
virtualHost string
Default
/The broker virtual host
Outputs
exchange string
The exchange name