from run_funs import run

try:
    from common_utils import adapter
except ModuleNotFoundError:
    from common_module.common_utils import adapter

try:
    from common_utils import rabbitmq
except ModuleNotFoundError:
    from common_module.common_utils import rabbitmq

if __name__ == "__main__":
    Worker = rabbitmq.Worker()
    Worker.register_callback(queue="queue_module_controller", callback=run)
    this_adapter = adapter.Adapter(Worker)
    this_adapter.start_listening()