queuebind
queuebind
Bind a queue to an AMQP exchange.
yaml
type: "io.kestra.plugin.amqp.queuebind"Examples
yaml
id: amqp_queue_bind
namespace: company.team
tasks:
- id: queue_bind
type: io.kestra.plugin.amqp.QueueBind
host: localhost
port: 5672
username: guest
password: guest
virtualHost: /my_vhost
exchange: kestramqp.exchange
queue: kestramqp.queue
Properties
exchange*Requiredstring
The exchange to bind with
host*Requiredstring
The broker host
queue*Requiredstring
The queue to bind
argsobject
Other properties (binding parameters)
passwordstring
The broker password
portstring
Default
5672The broker port
routingKeystring
The routing key to use for the binding
usernamestring
The broker username
virtualHoststring
Default
/The broker virtual host
Outputs
exchangestring
The exchange name
queuestring
The queue name