diff --git a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/AService.java b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/AService.java index 75b04720..7b81531c 100644 --- a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/AService.java +++ b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/AService.java @@ -24,7 +24,7 @@ public class AService implements AsyncTask, ParaExecto @Override public void callback(boolean success, DataContext param, TaskResult workResult) { if (success) { - System.out.println("AService 成功"); +// System.out.println("AService 成功"); } else { System.out.println("AService 失败"); } @@ -33,16 +33,15 @@ public void callback(boolean success, DataContext param, TaskResult @Override public DataContext task(DataContext params, GobrsAsyncSupport support) { try { -// System.out.println(1/0); Thread.sleep(1000); - System.out.println("AService 执行完了"); +// System.out.println("AService 执行完了"); } catch (InterruptedException e) { e.printStackTrace(); } - byte[] result = new byte[1024*1024]; +// byte[] result = new byte[1024*1024]; Map h = new HashMap(); - h.put("result", result); + h.put("result", h); params.setResult(h); return params; } diff --git a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/BService.java b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/BService.java index e3298f24..c1166774 100644 --- a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/BService.java +++ b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/BService.java @@ -26,7 +26,7 @@ public class BService implements AsyncTask, SerExector { @Override public void callback(boolean success, DataContext param, TaskResult workResult) { if (success) { - System.out.println("BService 成功"); +// System.out.println("BService 成功"); } else { System.out.println("BService 失败"); } diff --git a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/EService.java b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/EService.java index 0f07403e..7476b391 100644 --- a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/EService.java +++ b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/EService.java @@ -24,7 +24,7 @@ public class EService implements AsyncTask, ParaExecto @Override public void callback(boolean success, DataContext param, TaskResult workResult) { if (success) { - System.out.println("EService 成功"); +// System.out.println("EService 成功"); } else { System.out.println("EService 失败"); } @@ -32,7 +32,18 @@ public void callback(boolean success, DataContext param, TaskResult @Override public DataContext task(DataContext params, GobrsAsyncSupport support) { - stopTaskFlow(support, 100); + try { +// System.out.println(1/0); + Thread.sleep(500); + + + } catch (InterruptedException e) { + e.printStackTrace(); + } +// byte[] result = new byte[1024 * 1024]; + Map h = new HashMap(); + h.put("result", "我是EService 的 结果 恭喜你拿到"); + params.setResult(h); return params; } diff --git a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/FService.java b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/FService.java index 70e716b2..a27bf6af 100644 --- a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/FService.java +++ b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/FService.java @@ -23,7 +23,7 @@ public class FService implements AsyncTask, SerExector { @Override public void callback(boolean success, DataContext param, TaskResult workResult) { if (success) { - System.out.println("FService 成功"); +// System.out.println("FService 成功"); } else { System.out.println("FService 失败"); } @@ -32,8 +32,8 @@ public void callback(boolean success, DataContext param, TaskResult workRes @Override public Map task(DataContext params, GobrsAsyncSupport support) { try { - DataContext result = getResult(support, EService.class, DataContext.class); - System.out.println(JSONObject.toJSONString(result.getResult())); +// DataContext result = getResult(support, EService.class, DataContext.class); +// System.out.println(JSONObject.toJSONString(result.getResult())); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); diff --git a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/GobrsService.java b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/GobrsService.java index 30714457..b92edd69 100644 --- a/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/GobrsService.java +++ b/gobrs-async-example/src/main/java/com/jd/gobrs/async/example/service/GobrsService.java @@ -51,13 +51,6 @@ public void testGobrs(HttpServletRequest httpServletRequest) { DataContext dataContext = new DataContext(); dataContext.setHttpServletRequest(httpServletRequest); AsyncResult asyncResult = taskFlow.taskFlow("test", dataContext, 100000); - - if(asyncResult.getExpCode().equals(100)){ - // 业务一 - }else if(asyncResult.getExpCode().equals(200)){ - // 业务二 - } - } diff --git a/gobrs-async-example/src/main/resources/application.yml b/gobrs-async-example/src/main/resources/application.yml index 78404b3a..cf4952ba 100644 --- a/gobrs-async-example/src/main/resources/application.yml +++ b/gobrs-async-example/src/main/resources/application.yml @@ -3,6 +3,6 @@ server: spring: gobrs: async: - rules: '[{name: "test", content: "AService->BService,CService,GService,DService, FService:not;EService->FService"}]' + rules: '[{name: "test", content: "AService->BService;EService->FService"}]' # rules: '[{name: "test", content: "BService->CService->EService->DService:not;AService->DService:not"}]' task-interrupt: true #局部异常是否打断主流程 \ No newline at end of file