CreateQueueCreateQueue
CreateQueueCertified

Create an AMQP queue.

Create an AMQP queue.

Create a queue, including specified arguments.

yaml
type: "io.kestra.plugin.amqp.CreateQueue"
yaml
id: amqp_create_queue
namespace: company.team

tasks:
  - id: create_queue
    type: io.kestra.plugin.amqp.CreateQueue
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtualHost: /my_vhost
    name: kestramqp.queue
Properties

The broker host

The name of the queue

Other properties (construction arguments) for the queue

Defaultfalse

Specifies if declaring an auto-delete queue (server will delete it when no longer in use)

Defaulttrue

Specifies if declaring a durable queue (the queue will survive a server restart)

Defaultfalse

Specifies if declaring an exclusive queue (restricted to this connection)

The broker password

Default5672

The broker port

The broker username

Default/

The broker virtual host

The queue name