async def METHOD_NAME(
    disable_dynamic_service_background_task,
    enabled_rabbitmq: RabbitSettings,
    disabled_ec2: None,
    mocked_redis_server: None,
    initialized_app: FastAPI,
    rabbit_message: RabbitMessageBase,
    rabbitmq_client: Callable[[str], RabbitMQClient],
    mocker: MockerFixture,
):
    mocked_message_handler = mocker.AsyncMock(return_value=True)
    client = rabbitmq_client("pytest_consumer")
    await client.subscribe(
        rabbit_message.channel_name,
        mocked_message_handler,
        topics=[BIND_TO_ALL_TOPICS] if rabbit_message.routing_key() else None,
    )
    await post_message(initialized_app, message=rabbit_message)
    async for attempt in AsyncRetrying(**_TENACITY_RETRY_PARAMS):
        with attempt:
            print(
                f"--> checking for message in rabbit exchange {rabbit_message.channel_name}, {attempt.retry_state.retry_object.statistics}"
            )
            mocked_message_handler.assert_called_once_with(
                rabbit_message.json().encode()
            )
            print("... message received")