async def METHOD_NAME(self) -> None:
    self._is_ready = False
    await self._shutdown()
    try:
        await self._connect()
    except ConnectionAttemptFailed:
        return
    for exchange_name in list(self._exchanges.keys()):
        await self._declare_exchange(
            exchange_name, self._exchange_types[exchange_name]
        )
    self._is_ready = True