async def METHOD_NAME(self, data: Any, metadata: Any, service: Any) -> None:
    if data == self.data_uuid:
        if self.test_topic_specified_queue_name_data_received:
            raise Exception("test_topic_specified_queue_name_data_received already set")
        self.test_topic_specified_queue_name_data_received = True
        self.check_closer()