third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: support method job direct return ProcessResult #798

Browse Source
This commit is contained in:
tjq 2024-11-22 21:05:23 +08:00
parent 4fe2d7fdf1
commit 4e84bc60d7
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-worker/src/main/java/tech/powerjob/worker/processor/impl/MethodBasicProcessor.java
View File

@ -24,6 +24,12 @@ class MethodBasicProcessor implements BasicProcessor {
public ProcessResult process(TaskContext context) throws Exception { public ProcessResult process(TaskContext context) throws Exception {
try { try {
Object result = method.invoke(bean, context); 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)); return new ProcessResult(true, JsonUtils.toJSONString(result));
} catch (InvocationTargetException ite) { } catch (InvocationTargetException ite) {
ExceptionUtils.rethrow(ite.getTargetException()); ExceptionUtils.rethrow(ite.getTargetException());