Skip to content

FakeRabbitDeclarer

faststream.rabbit.helpers.declarer.FakeRabbitDeclarer #

Bases: RabbitDeclarer

disconnect #

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

declare_queue async #

declare_queue(queue, declare=EMPTY, *, channel=None)
Source code in faststream/rabbit/helpers/declarer.py 
46
47
48
49
50
51
52
53
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, declare=EMPTY, *, channel=None)
Source code in faststream/rabbit/helpers/declarer.py 
55
56
57
58
59
60
61
62
async def declare_exchange(
    self,
    exchange: "RabbitExchange",
    declare: bool = EMPTY,
    *,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustExchange":
    raise NotImplementedError