From 515ce9bce2511c64983b011bc0e64823a104d790 Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 10 Jan 2021 18:09:35 +0800 Subject: [PATCH] refacotr: no throw PowerJobException in OpenAPI --- .../com/github/kfcfans/powerjob/client/OhMyClient.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/powerjob-client/src/main/java/com/github/kfcfans/powerjob/client/OhMyClient.java b/powerjob-client/src/main/java/com/github/kfcfans/powerjob/client/OhMyClient.java index aac051cf..7b049b1e 100644 --- a/powerjob-client/src/main/java/com/github/kfcfans/powerjob/client/OhMyClient.java +++ b/powerjob-client/src/main/java/com/github/kfcfans/powerjob/client/OhMyClient.java @@ -192,7 +192,7 @@ public class OhMyClient { String post = postHA(OpenAPIConstant.RUN_JOB, builder.build()); return JSONObject.parseObject(post, LONG_RESULT_TYPE); } - public ResultDTO runJob(Long jobId) throws PowerJobException { + public ResultDTO runJob(Long jobId) { return runJob(jobId, null, 0); } @@ -357,7 +357,7 @@ public class OhMyClient { String post = postHA(OpenAPIConstant.RUN_WORKFLOW, builder.build()); return JSONObject.parseObject(post, LONG_RESULT_TYPE); } - public ResultDTO runWorkflow(Long workflowId) throws PowerJobException { + public ResultDTO runWorkflow(Long workflowId) { return runWorkflow(workflowId, null, 0); } @@ -367,7 +367,7 @@ public class OhMyClient { * @param wfInstanceId workflow instanceId * @return Standard return object */ - public ResultDTO stopWorkflowInstance(Long wfInstanceId) throws PowerJobException { + public ResultDTO stopWorkflowInstance(Long wfInstanceId) { RequestBody body = new FormBody.Builder() .add("wfInstanceId", wfInstanceId.toString()) .add("appId", appId.toString()) @@ -424,6 +424,6 @@ public class OhMyClient { } log.error("[OhMyClient] do post for path: {} failed because of no server available in {}.", path, allAddress); - throw new PowerJobException("no server available when send post"); + throw new PowerJobException("no server available when send post request"); } }