import os, sys
import threading

# add python path of src to sys.path
src_path = os.path.join(__file__, *(['..'] * 2))
src_path = os.path.abspath(src_path)
sys.path.insert(0, src_path)

from microwave.servers import MicroWaveUDPServer


class MicroWaveUDPThread (threading.Thread):
    def __init__(self, server_address, msg_queue):
        threading.Thread.__init__(self)
        self.udp_server = MicroWaveUDPServer(server_address, msg_queue)

    def run(self):
        print("MicroWaveUDPThread started")
        self.udp_server.serve_forever()

    def stop(self):
        self.udp_server.server_close()