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

refacotr: no throw PowerJobException in OpenAPI

Browse Source
This commit is contained in:
tjq 2021-01-10 18:09:35 +08:00
parent 2ecbc2c205
commit 515ce9bce2
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
powerjob-client/src/main/java/com/github/kfcfans/powerjob/client/OhMyClient.java
View File

@ -192,7 +192,7 @@ public class OhMyClient {
String post = postHA(OpenAPIConstant.RUN_JOB, builder.build()); String post = postHA(OpenAPIConstant.RUN_JOB, builder.build());
return JSONObject.parseObject(post, LONG_RESULT_TYPE); return JSONObject.parseObject(post, LONG_RESULT_TYPE);
} }
public ResultDTO<Long> runJob(Long jobId) throws PowerJobException { public ResultDTO<Long> runJob(Long jobId) {
return runJob(jobId, null, 0); return runJob(jobId, null, 0);
} }
@ -357,7 +357,7 @@ public class OhMyClient {
String post = postHA(OpenAPIConstant.RUN_WORKFLOW, builder.build()); String post = postHA(OpenAPIConstant.RUN_WORKFLOW, builder.build());
return JSONObject.parseObject(post, LONG_RESULT_TYPE); return JSONObject.parseObject(post, LONG_RESULT_TYPE);
} }
public ResultDTO<Long> runWorkflow(Long workflowId) throws PowerJobException { public ResultDTO<Long> runWorkflow(Long workflowId) {
return runWorkflow(workflowId, null, 0); return runWorkflow(workflowId, null, 0);
} }
@ -367,7 +367,7 @@ public class OhMyClient {
* @param wfInstanceId workflow instanceId * @param wfInstanceId workflow instanceId
* @return Standard return object * @return Standard return object
*/ */
public ResultDTO<Void> stopWorkflowInstance(Long wfInstanceId) throws PowerJobException { public ResultDTO<Void> stopWorkflowInstance(Long wfInstanceId) {
RequestBody body = new FormBody.Builder() RequestBody body = new FormBody.Builder()
.add("wfInstanceId", wfInstanceId.toString()) .add("wfInstanceId", wfInstanceId.toString())
.add("appId", appId.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); 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");
} }
} }