diff --git a/powerjob-common/src/main/java/tech/powerjob/common/serialize/JsonUtils.java b/powerjob-common/src/main/java/tech/powerjob/common/serialize/JsonUtils.java index ee40566a..77ca831c 100644 --- a/powerjob-common/src/main/java/tech/powerjob/common/serialize/JsonUtils.java +++ b/powerjob-common/src/main/java/tech/powerjob/common/serialize/JsonUtils.java @@ -20,7 +20,7 @@ import java.io.IOException; @Slf4j public class JsonUtils { - private static final JsonMapper OBJECT_MAPPER = JsonMapper.builder() + private static final JsonMapper JSON_MAPPER = JsonMapper.builder() .configure(MapperFeature.PROPAGATE_TRANSIENT_MARKER, true) .configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true) .configure(JsonParser.Feature.IGNORE_UNDEFINED, true) @@ -32,7 +32,7 @@ public class JsonUtils { public static String toJSONString(Object obj) { try { - return OBJECT_MAPPER.writeValueAsString(obj); + return JSON_MAPPER.writeValueAsString(obj); }catch (Exception e) { log.error("[PowerJob] toJSONString failed", e); } @@ -41,7 +41,7 @@ public class JsonUtils { public static String toJSONStringUnsafe(Object obj) { try { - return OBJECT_MAPPER.writeValueAsString(obj); + return JSON_MAPPER.writeValueAsString(obj); }catch (Exception e) { throw new PowerJobException(e); } @@ -49,7 +49,7 @@ public class JsonUtils { public static byte[] toBytes(Object obj) { try { - return OBJECT_MAPPER.writeValueAsBytes(obj); + return JSON_MAPPER.writeValueAsBytes(obj); }catch (Exception e) { log.error("[PowerJob] serialize failed", e); } @@ -57,24 +57,24 @@ public class JsonUtils { } public static T parseObject(String json, Class clz) throws JsonProcessingException { - return OBJECT_MAPPER.readValue(json, clz); + return JSON_MAPPER.readValue(json, clz); } public static T parseObject(byte[] b, Class clz) throws IOException { - return OBJECT_MAPPER.readValue(b, clz); + return JSON_MAPPER.readValue(b, clz); } public static T parseObject(byte[] b, TypeReference typeReference) throws IOException { - return OBJECT_MAPPER.readValue(b, typeReference); + return JSON_MAPPER.readValue(b, typeReference); } public static T parseObject(String json, TypeReference typeReference) throws IOException { - return OBJECT_MAPPER.readValue(json, typeReference); + return JSON_MAPPER.readValue(json, typeReference); } public static T parseObjectIgnoreException(String json, Class clz) { try { - return OBJECT_MAPPER.readValue(json, clz); + return JSON_MAPPER.readValue(json, clz); }catch (Exception e) { log.error("unable to parse json string to object,current string:{}",json,e); return null; @@ -84,7 +84,7 @@ public class JsonUtils { public static T parseObjectUnsafe(String json, Class clz) { try { - return OBJECT_MAPPER.readValue(json, clz); + return JSON_MAPPER.readValue(json, clz); }catch (Exception e) { ExceptionUtils.rethrow(e); } diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/FriendActor.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/FriendActor.java index 0b5a848f..8d7d56e3 100644 --- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/FriendActor.java +++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/FriendActor.java @@ -37,8 +37,7 @@ public class FriendActor { */ @Handler(path = S4S_HANDLER_PING, processType = ProcessType.NO_BLOCKING) public AskResponse onReceivePing(Ping ping) { - final AskResponse response = AskResponse.succeed(transportService.allProtocols()); - return response; + return AskResponse.succeed(transportService.allProtocols()); } @Handler(path = S4S_HANDLER_PROCESS, processType = ProcessType.BLOCKING)