|
@@ -43,37 +43,37 @@ public class SyncJoinTest extends AbstractExecutionFlowTest {
|
|
assertTrue(isActive("B"));
|
|
assertTrue(isActive("B"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("e");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("f");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("A"));
|
|
assertTrue(isActive("A"));
|
|
}
|
|
}
|
|
@@ -82,24 +82,24 @@ public class SyncJoinTest extends AbstractExecutionFlowTest {
|
|
assertTrue(isActive("B"));
|
|
assertTrue(isActive("B"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D1"));
|
|
assertTrue(isActive("D1"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("f");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("jc");
|
|
|
|
+ raiseEvent("jd");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("C1"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|
|
- raiseEvent("");
|
|
|
|
|
|
+ raiseEvent("e");
|
|
interpreter.runCycle();
|
|
interpreter.runCycle();
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("C2"));
|
|
assertTrue(isActive("D2"));
|
|
assertTrue(isActive("D2"));
|