def METHOD_NAME(self):
    sub = self.startProcess(
        command=self.sudo,
        arguments=[self.tedge, "mqtt", "sub", "--no-topic", "tedge/#"],
        stdouterr="tedge_sub",
        background=True,
    )
    # Wait for a small amount of time to give tedge sub time
    # to initialize. This is a heuristic measure.
    # Without an additional wait we observe failures in 1% of the test
    # runs.
    time.sleep(0.1)
    timestamp = time.time()
    temp_pub = self.startProcess(
        command=self.sudo,
        arguments=[
            self.tedge,
            "mqtt",
            "pub",
            "collectd/host/temperature/temp",
            f"{timestamp}:25.5",
        ],
        stdouterr="tedge_temp",
    )
    timestamp = time.time()
    pres_pub = self.startProcess(
        command=self.sudo,
        arguments=[
            self.tedge,
            "mqtt",
            "pub",
            "collectd/host/pressure/pres",
            f"{timestamp}:500.5",
        ],
        stdouterr="tedge_pres",
    )
    # wait for collectd-mapper to batch messages
    time.sleep(1)
    # Kill the subscriber process explicitly with sudo as PySys does
    # not have the rights to do it
    kill = self.startProcess(
        command=self.sudo,
        arguments=["killall", "tedge"],
        stdouterr="kill_out",
    )