def start_plugin(data_source_received):
    global data_source
    data_source = data_source_received
    try:
        thread = threading.Thread(target=listener)
        thread.start()
    except:
        print('Failed to start localization plugin')
def start_plugin(data_source_received):
    global data_source
    data_source = data_source_received
    try:
        thread = threading.Thread(target=listener)
        thread.start()
    except:
        print('Failed to start localization plugin')