diff --git a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java index 62138555..cf9282c4 100644 --- a/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java +++ b/powerjob-worker-samples/src/main/java/tech/powerjob/samples/tester/SpringMethodProcessorService.java @@ -9,9 +9,17 @@ import tech.powerjob.worker.log.OmsLogger; public class SpringMethodProcessorService { @PowerJob("test") - public void test(TaskContext context) { + public String test(TaskContext context) { OmsLogger omsLogger = context.getOmsLogger(); omsLogger.warn("测试日志"); - System.out.println("测试执行"); + return null; + } + + + @PowerJob("test1") + public String test1(TaskContext context) { + OmsLogger omsLogger = context.getOmsLogger(); + omsLogger.warn("测试日志"); + return "测试日志"; } } diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java index 84425ecc..b2634203 100644 --- a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java +++ b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/MethodBasicProcessor.java @@ -1,5 +1,6 @@ package tech.powerjob.worker.processor; +import tech.powerjob.common.serialize.JsonUtils; import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.TaskContext; import tech.powerjob.worker.core.processor.sdk.BasicProcessor; @@ -19,7 +20,7 @@ public class MethodBasicProcessor implements BasicProcessor { @Override public ProcessResult process(TaskContext context) throws Exception { - method.invoke(bean,context); - return new ProcessResult(true); + Object result = method.invoke(bean, context); + return new ProcessResult(true, JsonUtils.toJSONString(result)); } }