diff --git a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index a61784129..657b9b138 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-el/liteflow-testcase-el-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -17,11 +17,13 @@ public class ICmp { @LiteflowMethod(LiteFlowMethodEnum.PROCESS) public void process(NodeComponent bindCmp) throws Exception { DefaultContext context = bindCmp.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index 4674616b3..4ad3043bc 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-el/liteflow-testcase-el-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -10,11 +10,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")) { - Integer count = context.getData("count"); - context.setData("count", ++count); - } else { - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")) { + Integer count = context.getData("count"); + context.setData("count", ++count); + } else { + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index ba694aba0..323220296 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -12,11 +12,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index d3789bb8b..d85b775e8 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -13,11 +13,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow-exception.el.xml b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow-exception.el.xml index 10d593810..f88a6f727 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow-exception.el.xml +++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow-exception.el.xml @@ -1,11 +1,11 @@ - THEN(a, b, c) + THEN(a, b, c); - THEN(a, b, c) + THEN(a, b, c); diff --git a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow.el.xml b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow.el.xml index ee484e77c..e9563a4e3 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow.el.xml +++ b/liteflow-testcase-el/liteflow-testcase-el-springnative/src/test/resources/exception/flow.el.xml @@ -1,19 +1,19 @@ - THEN(a, b, c) + THEN(a, b, c); - THEN(a, WHEN(b, c).ignoreError(false)) + THEN(a, WHEN(b, c).ignoreError(false)); - THEN(c, d) + THEN(c, d); - SWITCH(e).to(b, c) + SWITCH(e).to(b, c); \ No newline at end of file diff --git a/liteflow-testcase-old/liteflow-testcase-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-old/liteflow-testcase-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index a61784129..657b9b138 100644 --- a/liteflow-testcase-old/liteflow-testcase-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-old/liteflow-testcase-declare-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -17,11 +17,13 @@ public class ICmp { @LiteflowMethod(LiteFlowMethodEnum.PROCESS) public void process(NodeComponent bindCmp) throws Exception { DefaultContext context = bindCmp.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-old/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-old/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index e3422fcf8..d2ff4d50d 100644 --- a/liteflow-testcase-old/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-old/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -11,11 +11,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")) { - Integer count = context.getData("count"); - context.setData("count", ++count); - } else { - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")) { + Integer count = context.getData("count"); + context.setData("count", ++count); + } else { + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-old/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-old/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index d3789bb8b..d85b775e8 100644 --- a/liteflow-testcase-old/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-old/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -13,11 +13,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException(); diff --git a/liteflow-testcase-old/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java b/liteflow-testcase-old/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java index d3789bb8b..d85b775e8 100644 --- a/liteflow-testcase-old/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java +++ b/liteflow-testcase-old/liteflow-testcase-springnative/src/test/java/com/yomahub/liteflow/test/asyncNode/cmp/ICmp.java @@ -13,11 +13,13 @@ public class ICmp extends NodeComponent { @Override public void process() throws Exception { DefaultContext context = this.getFirstContextBean(); - if (context.hasData("count")){ - Integer count = context.getData("count"); - context.setData("count", ++count); - } else{ - context.setData("count", 1); + synchronized (ICmp.class){ + if (context.hasData("count")){ + Integer count = context.getData("count"); + context.setData("count", ++count); + } else{ + context.setData("count", 1); + } } System.out.println("Icomp executed! throw Exception!"); throw new TestException();