QueueBind

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

Bind a queue to an exchange.

Examples

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

exchange

• Type: string
• Dynamic: ✔️
• Required: ✔️

The exchange to bind with.

queue

• Type: string
• Dynamic: ✔️
• Required: ✔️

The queue to bind.

args

• Type: object
• Dynamic: ❓
• Required: ❌

Other properties (binding parameters).

host

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker host.

password

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker password.

port

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker port.

routingKey

• Type: string
• Dynamic: ❓
• Required: ❌

The routing key to use for the binding.

username

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker username.

virtualHost

• Type: string
• Dynamic: ✔️
• Required: ❌

The broker virtual host.

Outputs

exchange

• Type: string
• Required: ❌

The exchange name.

queue

• Type: string
• Required: ❌

The queue name.