AMQP DeclareExchange
CertifiedCreate an AMQP exchange
AMQP DeclareExchange
Create an AMQP exchange
Declares an exchange on the broker, creating it with the given type and durability if it does not already exist.
type: io.kestra.plugin.amqp.DeclareExchangeExamples
id: amqp_declare_exchange
namespace: company.team
tasks:
- id: declare_exchange
type: io.kestra.plugin.amqp.DeclareExchange
host: localhost
port: 5672
username: guest
password: "{{ secret('AMQP_PASSWORD') }}"
virtualHost: /my_vhost
name: kestramqp.exchange
Properties
host *string
Broker host
Hostname or IP of the RabbitMQ broker; required unless using the deprecated url.
name *string
The name of the exchange
args object
Other properties (construction arguments) for the exchange
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150autoDelete booleanstring
falseSpecifies if the server should delete the exchange when it is no longer in use
durability booleanstring
trueSpecifies if declaring a durable exchange (the exchange will survive a server restart)
exchangeType string
DIRECTDIRECTFANOUTTOPICHEADERSCONSISTENT_HASHMODULUS_HASHLOCAL_RANDOMRANDOMThe exchange type
internal booleanstring
falseSpecifies if the exchange is internal, i.e., can't be directly published to by a client
password string
Password
Password for the connection; required when the broker enforces authentication.
port string
5672Broker 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
/Virtual host
Broker virtual host path; defaults to /.
Outputs
exchange string
The exchange name
