Bindings

Managing RabbitMQ bindings between exchanges and queues/exchanges.

all() -> list[dict] async

List all bindings in the cluster.

bind_exchange_to_exchange(vhost: str, source: str, destination: str, *, routing_key: Optional[str] = None, arguments: Optional[dict] = None) -> str async

Create a binding between two exchanges.

Returns: 'location' URI of the new binding.

bind_exchange_to_queue(vhost: str, exchange: str, queue: str, *, routing_key: Optional[str] = None, arguments: Optional[dict] = None) -> str async

Create a binding between an exchange and a queue.

Returns: 'location' URI of the new binding.

by_vhost(vhost: str) -> list[dict] async

List all bindings in a specific virtual host.

exchange_to_exchange(vhost: str, source: str, destination: str) -> list[dict] async

List all bindings between two exchanges.

exchange_to_exchange_binding_details(vhost: str, source: str, destination: str, properties_key: str) -> dict async

Get details of a specific exchange-to-exchange binding.

Parameters:

Name	Type	Description	Default
properties_key	str	Unique binding ID (routing_key + args hash) from the bindings list.	required

exchange_to_queue(vhost: str, exchange: str, queue: str) -> list[dict] async

List all bindings between a specific exchange and a queue.

exchange_to_queue_binding_details(vhost: str, exchange: str, queue: str, properties_key: str) -> dict async

Get details of a specific exchange-to-queue binding.

Parameters:

Name	Type	Description	Default
properties_key	str	Unique binding ID (routing_key + args hash) from the bindings list.	required

unbind_exchange_from_exchange(vhost: str, source: str, destination: str, properties_key: str) -> dict async

Delete a binding between two exchanges using its properties_key.

Parameters:

Name	Type	Description	Default
properties_key	str	Unique binding ID (routing_key + args hash) from the bindings list.	required

unbind_exchange_from_queue(vhost: str, exchange: str, queue: str, properties_key: str) -> dict async

Delete a binding between an exchange and a queue using its properties_key.

Parameters:

Name	Type	Description	Default
properties_key	str	Unique binding ID (routing_key + args hash) from the bindings list.	required