Skip to content

ChannelManager

faststream.rabbit.helpers.ChannelManager #

Bases: Protocol

connect #

connect(connection: RobustConnection) -> None
Source code in faststream/rabbit/helpers/channel_manager.py 
14
def connect(self, connection: "aio_pika.RobustConnection") -> None: ...

disconnect #

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

get_channel async #

get_channel(
    channel: Optional[Channel] = None,
) -> RobustChannel

Declare a channel.

Source code in faststream/rabbit/helpers/channel_manager.py 
18
19
20
21
22
23
async def get_channel(
    self,
    channel: Optional["Channel"] = None,
) -> "aio_pika.RobustChannel":
    """Declare a channel."""
    ...