[incubator-kie-issues-1131] testSubProcessWithTerminateEndEventProces…

…sScope changes
apache · May 21, 2024 · bea3415 · bea3415
1 parent 5c499ff
commit bea3415
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/jbpm/jbpm-tests/src/test/java/org/jbpm/bpmn2/ActivityTest.java b/jbpm/jbpm-tests/src/test/java/org/jbpm/bpmn2/ActivityTest.java
@@ -649,19 +649,25 @@ public void testSubProcessWithTerminateEndEvent() {
     public void testSubProcessWithTerminateEndEventProcessScope() {
 
         Application app = ProcessTestHelper.newApplication();
-        EventTrackerProcessListener listener = new EventTrackerProcessListener();
+        final List<String> nodeList = new ArrayList<>();
+        EventTrackerProcessListener listener = new EventTrackerProcessListener() {
+
+            @Override
+            public void afterNodeTriggered(ProcessNodeTriggeredEvent event) {
+                NodeInstance nodeInstance = event.getNodeInstance();
+                if (!(nodeInstance instanceof EndNodeInstance || nodeInstance instanceof StartNodeInstance)) {
+                    nodeList.add(nodeInstance.getNodeName());
+                }
+            }
+        };
         ProcessTestHelper.registerProcessEventListener(app, listener);
         org.kie.kogito.process.Process<SubProcessWithTerminateEndEventProcessScopeModel> processDefinition = SubProcessWithTerminateEndEventProcessScopeProcess.newProcess(app);
         SubProcessWithTerminateEndEventProcessScopeModel model = processDefinition.createModel();
 
         org.kie.kogito.process.ProcessInstance<SubProcessWithTerminateEndEventProcessScopeModel> instance = processDefinition.createInstance(model);
         instance.start();
-        Set<NodeInstance> processNodeEvents = listener.tracked().stream()
-                .map(ProcessNodeEvent::getNodeInstance)
-                .filter(nodeInstance -> !(nodeInstance instanceof EndNodeInstance || nodeInstance instanceof StartNodeInstance))
-                .collect(Collectors.toSet());
         assertThat(instance).extracting(ProcessInstance::status).isEqualTo(ProcessInstance.STATE_COMPLETED);
-        assertThat(processNodeEvents).hasSize(3);
+        assertThat(nodeList).hasSize(3);
     }
 
     @Test