DeclareExchange
Create an AMQP exchange.
yaml
type: "io.kestra.plugin.amqp.DeclareExchange"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
The name of the exchange.
Other properties (construction arguments) for the exchange.
Default
falseSpecify if the server should delete the exchange when it is no longer in use.
Default
trueSpecify if we are declaring a durable exchange (the exchange will survive a server restart).
Default
DIRECT Possible Values
DIRECTFANOUTTOPICHEADERSThe exchange type.
The broker host.
Default
falseSpecify if the exchange is internal, i.e. can't be directly published to by a client.
The broker password.
The broker port.
The broker username.
The broker virtual host.
The exchange name.