From 4e84bc60d7b8cb9bc9fb058aa4e86b442ea78589 Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Fri, 22 Nov 2024 21:05:23 +0800
Subject: [PATCH] feat: support method job direct return ProcessResult #798

---
 .../worker/processor/impl/MethodBasicProcessor.java         | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/impl/MethodBasicProcessor.java b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/impl/MethodBasicProcessor.java
index b148591f..8912cf8f 100644
--- a/powerjob-worker/src/main/java/tech/powerjob/worker/processor/impl/MethodBasicProcessor.java
+++ b/powerjob-worker/src/main/java/tech/powerjob/worker/processor/impl/MethodBasicProcessor.java
@@ -24,6 +24,12 @@ class MethodBasicProcessor implements BasicProcessor {
     public ProcessResult process(TaskContext context) throws Exception {
         try {
             Object result = method.invoke(bean, context);
+
+            // 支持直接返回 ProcessResult  https://github.com/PowerJob/PowerJob/issues/798
+            if (result instanceof ProcessResult) {
+                return (ProcessResult) result;
+            }
+
             return new ProcessResult(true, JsonUtils.toJSONString(result));
         } catch (InvocationTargetException ite) {
             ExceptionUtils.rethrow(ite.getTargetException());