From ec47f5a8c50c841da724de08853d28a6ea94ac5a Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Sun, 18 Sep 2022 00:22:03 +0800
Subject: [PATCH] feat: add ConfigProcessor in official-processor

---
 .../powerjob/official/processors/impl/ConfigProcessor.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/ConfigProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/ConfigProcessor.java
index f92ec4c2..6d6e1e0e 100644
--- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/ConfigProcessor.java
+++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/impl/ConfigProcessor.java
@@ -1,12 +1,12 @@
 package tech.powerjob.official.processors.impl;
 
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Maps;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
+import tech.powerjob.common.serialize.JsonUtils;
 import tech.powerjob.official.processors.util.CommonUtils;
 import tech.powerjob.worker.core.processor.ProcessResult;
 import tech.powerjob.worker.core.processor.TaskContext;
@@ -47,7 +47,7 @@ public class ConfigProcessor implements BroadcastProcessor {
     @Override
     public ProcessResult process(TaskContext context) throws Exception {
 
-        Config newCfg = JSON.parseObject(CommonUtils.parseParams(context), Config.class);
+        Config newCfg = JsonUtils.parseObject(CommonUtils.parseParams(context), Config.class);
         context.getOmsLogger().info("[ConfigProcessor] receive and update config: {}", config);
 
         // 空场景不更新