AMQP QueueBind

AMQP QueueBind
Certified
Bind a queue to an AMQP exchange

Binds an existing queue to an exchange with a routing key so the queue receives matching messages.

yaml
type: io.kestra.plugin.amqp.QueueBind

Examples

yaml
id: amqp_queue_bind
namespace: company.team

tasks:
  - id: queue_bind
    type: io.kestra.plugin.amqp.QueueBind
    host: localhost
    port: 5672
    username: guest
    password: "{{ secret('AMQP_PASSWORD') }}"
    virtualHost: /my_vhost
    exchange: kestramqp.exchange
    queue: kestramqp.queue

Properties

exchange *string

The exchange to bind with

host *string

Broker host

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

queue *string

The queue to bind

args object

Other properties (binding parameters)

password string

Password

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

pluginDefaultsRef string

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

port string

Default5672

Broker port

TCP port for AMQP connections; defaults to 5672.

routingKey string

The routing key to use for the binding

username string

Username

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

virtualHost string

Default/

Virtual host

Broker virtual host path; defaults to /.

Outputs

exchange string

The exchange name

queue string

The queue name

Liquibase

Tasks that run Liquibase change management commands.

Data

OPA (Open Policy Agent)

Enterprise

Tasks to manage Open Policy Agent policies and decisions, including upload, evaluation, and partial evaluation.

Infrastructure

AMQP QueueBindCertifiedBind a queue to an AMQP exchange

AMQP QueueBind

More Plugins in this Category

Liquibase

OPA (Open Policy Agent)

AMQP QueueBind
Certified
Bind a queue to an AMQP exchange