Skip to content

FakeRabbitDeclarer

faststream.rabbit.helpers.declarer.FakeRabbitDeclarer #

Bases: RabbitDeclarer

disconnect #

disconnect() -> None
Source code in faststream/rabbit/helpers/declarer.py 
44
45
def disconnect(self) -> None:
    raise NotImplementedError

declare_queue async #

declare_queue(
    queue: RabbitQueue,
    declare: bool = EMPTY,
    *,
    channel: Optional[Channel] = None,
) -> RobustQueue
Source code in faststream/rabbit/helpers/declarer.py 
47
48
49
50
51
52
53
54
async def declare_queue(
    self,
    queue: "RabbitQueue",
    declare: bool = EMPTY,
    *,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustQueue":
    raise NotImplementedError

declare_exchange async #

declare_exchange(
    exchange: RabbitExchange,
    declare: bool = EMPTY,
    *,
    channel: Optional[Channel] = None,
) -> RobustExchange
Source code in faststream/rabbit/helpers/declarer.py 
56
57
58
59
60
61
62
63
async def declare_exchange(
    self,
    exchange: "RabbitExchange",
    declare: bool = EMPTY,
    *,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustExchange":
    raise NotImplementedError