Create an 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 false

Specify if the server should delete the exchange when it is no longer in use.

Default true

Specify if we are declaring a durable exchange (the exchange will survive a server restart).

Default DIRECT

Possible Values

DIRECTFANOUTTOPICHEADERS

The exchange type.

The broker host.

Default false

Specify 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.