def METHOD_NAME(start_task_q_publisher, start_task_q_subscriber):
    """Confirm that messages published are received."""
    task_q_pub = start_task_q_publisher()
    tasks_out = multiprocessing.Queue()
    start_task_q_subscriber(queue=tasks_out)
    latency = []
    for i in range(100):
        b_message = f"Hello World! {i}".encode()
        start_t = time.time()
        task_q_pub.publish(b_message)
        _, x = tasks_out.get()
        delta = time.time() - start_t
        latency.append(delta)
        assert b_message == x
    avg_latency = sum(latency) / len(latency)
    logging.warning(
        f"Message latencies in milliseconds, min:{1000*min(latency):.2f}, "
        f"max:{1000*max(latency):.2f}, avg:{1000*avg_latency:.2f}"
    )
    # average latency is expected to be below 5ms
    # if it exceeds this, it means something is wrong
    assert avg_latency < 0.005