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
url
- Type: string
- Dynamic: ✔️
- Required: ✔️
The connection string
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)
Outputs
queue
- Type: string
Queue name