async def METHOD_NAME(
    disable_dynamic_service_background_task,
    enabled_rabbitmq: RabbitSettings,
    disabled_ec2: None,
    mocked_redis_server: None,
    initialized_app: FastAPI,
    rabbitmq_client: Callable[[str], RabbitMQClient],
    mocker: MockerFixture,
    async_docker_client: aiodocker.Docker,
    create_service: Callable[
        [dict[str, Any], dict[DockerLabelKey, str], str], Awaitable[Service]
    ],
    task_template: dict[str, Any],
    osparc_docker_label_keys: StandardSimcoreDockerLabels,
    faker: Faker,
):
    mocked_message_handler = mocker.AsyncMock(return_value=True)
    client = rabbitmq_client("pytest_consumer")
    await client.subscribe(
        ProgressRabbitMessageNode.get_channel_name(),
        mocked_message_handler,
        topics=[BIND_TO_ALL_TOPICS],
    )
    service_with_labels = await create_service(
        task_template,
        osparc_docker_label_keys.to_simcore_runtime_docker_labels(),
        "running",
    )
    assert service_with_labels.Spec
    service_tasks = parse_obj_as(
        list[Task],
        await async_docker_client.tasks.list(
            filters={"service": service_with_labels.Spec.Name}
        ),
    )
    assert service_tasks
    assert len(service_tasks) == 1
    progress_value = faker.pyfloat(min_value=0)
    await post_task_progress_message(initialized_app, service_tasks[0], progress_value)
    async for attempt in AsyncRetrying(**_TENACITY_RETRY_PARAMS):
        with attempt:
            print(
                f"--> checking for message in rabbit exchange {ProgressRabbitMessageNode.get_channel_name()}, {attempt.retry_state.retry_object.statistics}"
            )
            mocked_message_handler.assert_called_once_with(
                ProgressRabbitMessageNode(
                    node_id=osparc_docker_label_keys.node_id,
                    project_id=osparc_docker_label_keys.project_id,
                    user_id=osparc_docker_label_keys.user_id,
                    progress=progress_value,
                    progress_type=ProgressType.CLUSTER_UP_SCALING,
                )
                .json()
                .encode()
            )
            print("... message received")