34
34
import org .kie .kogito .Model ;
35
35
import org .kie .kogito .internal .process .runtime .KogitoProcessInstance ;
36
36
import org .kie .kogito .internal .process .runtime .KogitoProcessRuntime ;
37
+ import org .kie .kogito .process .MutableProcessInstances ;
37
38
import org .kie .kogito .uow .UnitOfWork ;
38
39
import org .kie .kogito .uow .UnitOfWorkManager ;
39
40
import org .mockito .Mock ;
@@ -60,6 +61,9 @@ public class AbstractProcessInstanceTest {
60
61
@ Mock
61
62
private UnitOfWork unitOfWork ;
62
63
64
+ @ Mock
65
+ private MutableProcessInstances instances ;
66
+
63
67
private AbstractProcessInstance <TestModel > processInstance ;
64
68
65
69
@ SuppressWarnings ("unchecked" )
@@ -70,6 +74,7 @@ public void setup() {
70
74
AbstractProcess <TestModel > process = mock (AbstractProcess .class );
71
75
Process piProcess = mock (Process .class );
72
76
when (process .process ()).thenReturn (piProcess );
77
+ when (process .instances ()).thenReturn (instances );
73
78
when (process .get ()).thenReturn (piProcess );
74
79
InternalProcessRuntime pr = mock (InternalProcessRuntime .class );
75
80
when (pr .createProcessInstance (any (), any (), any ())).thenReturn (wpi );
@@ -100,7 +105,7 @@ public void shouldTriggerNodeWhenStartFrom() {
100
105
processInstance .startFrom (NODE_ID );
101
106
102
107
verify (nodeInstance ).trigger (null , Node .CONNECTION_DEFAULT_TYPE );
103
- verify (unitOfWork , times (4 )).intercept (any ());
108
+ verify (unitOfWork , times (0 )).intercept (any ());
104
109
}
105
110
106
111
@ Test
@@ -110,7 +115,7 @@ public void shouldTriggerNodeWhenTrigger() {
110
115
processInstance .triggerNode (NODE_ID );
111
116
112
117
verify (nodeInstance ).trigger (null , Node .CONNECTION_DEFAULT_TYPE );
113
- verify (unitOfWork , times (2 )).intercept (any ());
118
+ verify (unitOfWork , times (0 )).intercept (any ());
114
119
}
115
120
116
121
private NodeInstance givenExistingNode (String nodeId ) {
0 commit comments