CreateQueue

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

Create a Queue

Create a Queue, including specified arguments

Examples

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