DeclareExchange
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
host: localhost
port: 5672
username: guest
password: guest
virtualHost: /my_vhost
name: kestramqp.exchange
Properties
host*Requiredstring
The broker host
name*Requiredstring
The name of the exchange
argsobject
Other properties (construction arguments) for the exchange
autoDeletebooleanstring
Default
falseSpecifies if the server should delete the exchange when it is no longer in use
durabilitybooleanstring
Default
trueSpecifies if declaring a durable exchange (the exchange will survive a server restart)
exchangeTypestring
Default
DIRECTPossible Values
DIRECTFANOUTTOPICHEADERSThe exchange type
internalbooleanstring
Default
falseSpecifies if the exchange is internal, i.e., can't be directly published to by a client
passwordstring
The broker password
portstring
Default
5672The broker port
usernamestring
The broker username
virtualHoststring
Default
/The broker virtual host
Outputs
exchangestring
The exchange name
