pluginsplugin-amqp

QueueBind​Queue​Bind

Bind a queue to an AMQP exchange.

yaml
type: "io.kestra.plugin.amqp.QueueBind"
yaml
id: amqp_queue_bind
namespace: company.team

tasks:
  - id: queue_bind
    type: io.kestra.plugin.amqp.QueueBind
    url: amqp://guest:guest@localhost:5672/my_vhost
    exchange: kestramqp.exchange
    queue: kestramqp.queue
Properties

The exchange to bind with.

The broker host.

The queue to bind.

Other properties (binding parameters).

The broker password.

Default 5672

The broker port.

The routing key to use for the binding.

The broker username.

Default /

The broker virtual host.

The exchange name.

The queue name.