Managing connection to broker via custom entity

[allcupsnotinprivate]

I use fastapi plugin to integrate queue handlers into the application. When the application starts, a connection to the broker is established.

@contextlib.asynccontextmanager
async def lifespan(app: FastAPI) -> AsyncIterator[None]:
      async with queues_router.lifespan_context(app):
          # for example: await postgres.startup()
          yield
          # for example: await postgres.shutdown()


def create_application():

    app = FastAPI(
        title=app_settings.app.title,
        version=app_settings.app.version,
        docs_url=app_settings.app.docs_url,
        redoc_url=app_settings.app.redoc_url,
        lifespan=lifespan  # noqa
    )

    rabbitmq_router = RabbitRouter(
        rabbitmq_settings.url, fail_fast=False, logger=None, middlewares=[...]
    )
    rabbitmq_router.include_router(external_router)

    app.include_router(rabbitmq_router)
    return app

Can I somehow manage the connection. For example, in the following case: I should have some callable object to establish a connection to the broker with custom retries (for example, tenacity), and I should also be able to add custom logs in the required places inside the callable object (for example, logger.info(...)). And as a main goal, the application should still start if the connection to the broker fails.
Are there any internal framework capabilities for this? Or how can I integrate my own?