Skip to content

RabbitDeclarer

faststream.rabbit.helpers.RabbitDeclarer #

Bases: Protocol

An utility class to declare RabbitMQ queues and exchanges.

disconnect #

disconnect() -> None
Source code in faststream/rabbit/helpers/declarer.py 
19
def disconnect(self) -> None: ...

declare_queue async #

declare_queue(
    queue: RabbitQueue,
    declare: bool = EMPTY,
    *,
    channel: Optional[Channel] = None,
) -> RobustQueue

Declare a queue.

Source code in faststream/rabbit/helpers/declarer.py 
21
22
23
24
25
26
27
28
29
async def declare_queue(
    self,
    queue: "RabbitQueue",
    declare: bool = EMPTY,
    *,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustQueue":
    """Declare a queue."""
    ...

declare_exchange async #

declare_exchange(
    exchange: RabbitExchange,
    declare: bool = EMPTY,
    *,
    channel: Optional[Channel] = None,
) -> RobustExchange

Declare an exchange, parent exchanges and bind them each other.

Source code in faststream/rabbit/helpers/declarer.py 
31
32
33
34
35
36
37
38
39
async def declare_exchange(
    self,
    exchange: "RabbitExchange",
    declare: bool = EMPTY,
    *,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustExchange":
    """Declare an exchange, parent exchanges and bind them each other."""
    ...