CreateQueue

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

Create a queue.

Create a queue, including specified arguments.

Examples

id: amqp_create_queue
namespace: company.team

tasks:
  - 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

Specify if we are declaring an auto-delete queue (server will delete it when no longer in use).

durability

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

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

exclusive

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

Specify 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
• Required: ❌

The queue name.