def METHOD_NAME(self):
    # publish a message
    mqtt_pub = self.startProcess(
        command=self.sudo,
        arguments=[
            self.tedge,
            "mqtt",
            "pub",
            "tedge/measurements",
            '{ "temperature": 25 }',
        ],
        stdouterr="mqtt_pub",
    )
    # check if the file exists
    self.check_if_sub_logged()
    # Stop the subscriber
    kill = self.startProcess(
        command=self.sudo,
        arguments=["killall", "tedge"],
        stdouterr="kill_out",
    )
    self.assertGrep("mqtt_sub.out", '{ "temperature": 25 }', contains=True)