AMQP DeclareExchange

AMQP DeclareExchange

Certified

Create an AMQP exchange

Declares an exchange on the broker, creating it with the given type and durability if it does not already exist.

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
    host: localhost
    port: 5672
    username: guest
    password: "{{ secret('AMQP_PASSWORD') }}"
    virtualHost: /my_vhost
    name: kestramqp.exchange
Properties

Broker host

Hostname or IP of the RabbitMQ broker; required unless using the deprecated url.

The name of the exchange

Other properties (construction arguments) for the exchange

Defaultfalse

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

Defaulttrue

Specifies if declaring a durable exchange (the exchange will survive a server restart)

DefaultDIRECT
Possible Values
DIRECTFANOUTTOPICHEADERSCONSISTENT_HASHMODULUS_HASHLOCAL_RANDOMRANDOM

The exchange type

Defaultfalse

Specifies if the exchange is internal, i.e., can't be directly published to by a client

Password

Password for the connection; required when the broker enforces authentication.

Reference (ref) of the pluginDefaults to apply to this task.

Default5672

Broker port

TCP port for AMQP connections; defaults to 5672.

Username

Username for the connection; uses broker default (often guest) when not set.

Default/

Virtual host

Broker virtual host path; defaults to /.

The exchange name

More Plugins in this Category

Liquibase
Liquibase

Tasks that run Liquibase change management commands.

Data

2 tasks

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

6 tasks

25 blueprints