PluginsAMQPTasksQueueBind

QueueBind​Queue​Bind

QueueBind QueueBind

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

Bind a queue to an exchange.

Examples

yaml
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
  • Dynamic: ❓
  • Required: ❌

The exchange name.

queue

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

The queue name.