PLUGINSPLUGIN-AMQPTASKSIO.KESTRA.PLUGIN.AMQP.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.

url

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

The connection string

args

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

Other properties (binding parameters).

routingKey

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

The routing key to use for the binding.

Outputs

exchange

  • Type: string

The exchange name

queue

  • Type: string

The queue name