private void dealWithConfigQueue(BlockingQueue<ConfigResult> queue) {
        ConfigResult config = queue.poll();
        if (config == null) {
            return;
        }
        LOGGER.info("deal with config {}", GSON.toJson(config));
        if (currentMd5.equals(config.getMd5())) {
            LOGGER.info("md5 no change {}, skip update", currentMd5);
            return;
        }
        if (updateModules(config.getModuleList())) {
            currentMd5 = config.getMd5();
            currentVersion = config.getVersion();
            saveToLocalFile(confPath);
        } else {
            LOGGER.error("update modules failed!");
        }
    }
Thread for core thread.

@return runnable profile.
inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java