diff --git a/powerjob-official-processors/pom.xml b/powerjob-official-processors/pom.xml index 619cd1c1..edb8a218 100644 --- a/powerjob-official-processors/pom.xml +++ b/powerjob-official-processors/pom.xml @@ -5,7 +5,7 @@ powerjob com.github.kfcfans - 2.0.0 + 3.0.0 4.0.0 @@ -95,10 +95,6 @@ org shade.powerjob.org - - javax - shade.powerjob.javax - com.google shade.powerjob.com.google diff --git a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java index 564bc349..56d60fe4 100644 --- a/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java +++ b/powerjob-official-processors/src/main/java/tech/powerjob/official/processors/CommonBasicProcessor.java @@ -26,21 +26,13 @@ public abstract class CommonBasicProcessor implements BasicProcessor { Stopwatch sw = Stopwatch.createStarted(); ProcessResult result = process0(taskContext); omsLogger.info("[{}] execute succeed, using {}, result: {}", clzName, sw, result); - return suit(result); + return result; } catch (Throwable t) { omsLogger.error("[{}] execute failed!", clzName, t); return new ProcessResult(false, ExceptionUtils.getMessage(t)); } } - private static ProcessResult suit(ProcessResult processResult) { - if (processResult.getMsg() == null || processResult.getMsg().length() < 1024) { - return processResult; - } - processResult.setMsg(processResult.getMsg().substring(0, 1024) + "..."); - return processResult; - } - protected abstract ProcessResult process0(TaskContext taskContext) throws Exception; }