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
falseSpecify if the server should delete the exchange when it is no longer in use.
durability booleanstring
Default
trueSpecify if we are declaring a durable exchange (the exchange will survive a server restart).
exchangeType string
Default
DIRECT Possible Values
DIRECTFANOUTTOPICHEADERSThe exchange type.
internal booleanstring
Default
falseSpecify 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.