AMQP CreateQueue

AMQP CreateQueue
Certified
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
    host: localhost
    port: 5672
    username: guest
    password: "{{ secret('AMQP_PASSWORD') }}"
    virtualHost: /my_vhost
    name: kestramqp.queue

Properties

host *string

Broker host

Hostname or IP of the RabbitMQ broker; required unless using the deprecated url.

name *string

The name of the queue

args object

Other properties (construction arguments) for the queue

autoDelete booleanstring

Defaultfalse

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

durability booleanstring

Defaulttrue

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

exclusive booleanstring

Defaultfalse

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

password string

Password

Password for the connection; required when the broker enforces authentication.

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

port string

Default5672

Broker port

TCP port for AMQP connections; defaults to 5672.

username string

Username

Username for the connection; uses broker default (often guest) when not set.

virtualHost string

Default/

Virtual host

Broker virtual host path; defaults to /.

Outputs

queue string

The queue name

Liquibase

Tasks that run Liquibase change management commands.

Data

OPA (Open Policy Agent)

Enterprise

Tasks to manage Open Policy Agent policies and decisions, including upload, evaluation, and partial evaluation.

Infrastructure

AMQP CreateQueueCertifiedCreate an AMQP queue

AMQP CreateQueue

More Plugins in this Category

Liquibase

OPA (Open Policy Agent)

AMQP CreateQueue
Certified
Create an AMQP queue