def METHOD_NAME(start_task_q_publisher, start_task_q_subscriber):
    """2 subscribers connect, only first one should get any messages"""
    task_q_pub = start_task_q_publisher()
    # Start two subscribers on the same rabbit queue
    tasks_out_1, tasks_out_2 = multiprocessing.Queue(), multiprocessing.Queue()
    start_task_q_subscriber(queue=tasks_out_1)
    time.sleep(1)
    start_task_q_subscriber(queue=tasks_out_2)
    logging.warning("TEST: Launching messages")
    # Launch 10 messages
    messages = []
    for i in range(10):
        message = {
            "task_id": str(uuid.uuid4()),
            "result": f"foo={i}",
        }
        b_message = json.dumps(message).encode("utf-8")
        task_q_pub.publish(b_message)
        messages.append(b_message)
    logging.warning("TEST: Launching messages")
    # Confirm that the first subscriber received all the messages
    for i in range(10):
        _, message = tasks_out_1.get(timeout=1)
        logging.warning(f"Got message: {message}")
        assert messages[i] == message
    # Check that the second subscriber did not receive any messages
    assert tasks_out_2.empty()