🚀 New! Kestra raises $3 million to grow Learn more

CreateQueue CreateQueue

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

Create a Queue

Create a Queue, including specified arguments

Examples

yaml
id: "create_queue"
type: "io.kestra.plugin.amqp.CreateQueue"
url: amqp://guest:guest@localhost:5672/my_vhost
name: kestramqp.queue

Properties

name

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

The name of the queue

args

  • Type: object
  • Dynamic:
  • Required:

Other properties (construction arguments) for the queue

autoDelete

  • Type: boolean
  • Dynamic:
  • Required:
  • Default: false

True if we are declaring an autodelete queue (server will delete it when no longer in use)

durability

  • Type: boolean
  • Dynamic:
  • Required:
  • Default: true

True if we are declaring a durable queue (the queue will survive a server restart)

exclusive

  • Type: boolean
  • Dynamic:
  • Required:
  • Default: false

True if we are declaring an exclusive queue (restricted to this connection)

host

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

The broker host

password

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

The broker password

port

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

The broker port

username

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

The broker username

virtualHost

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

The broker virtual host

Outputs

queue

  • Type: string

Queue name