CreateQueue
Create an AMQP queue.
Create a queue, including specified arguments.
yaml
type: "io.kestra.plugin.amqp.CreateQueue"Examples
yaml
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
host *Requiredstring
The broker host
name *Requiredstring
The name of the queue
args object
Other properties (construction arguments) for the queue
autoDelete booleanstring
Default
falseSpecifies if declaring an auto-delete queue (server will delete it when no longer in use)
durability booleanstring
Default
trueSpecifies if declaring a durable queue (the queue will survive a server restart)
exclusive booleanstring
Default
falseSpecifies if declaring an exclusive queue (restricted to this connection)
password string
The broker password
port string
Default
5672The broker port
username string
The broker username
virtualHost string
Default
/The broker virtual host
Outputs
queue string
The queue name