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
falseSpecify if we are declaring an auto-delete queue (server will delete it when no longer in use).
durability booleanstring
Default
trueSpecify if we are declaring a durable queue (the queue will survive a server restart).
exclusive booleanstring
Default
falseSpecify if we are 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.