@@ -105,8 +105,7 @@ public void notGenerationAwareSchedulingProcessesAllEventsRegardlessOfGeneration
105
105
.matches (list -> eventProcessingList .get (0 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("1" ) &&
106
106
eventProcessingList .get (1 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("2" ),
107
107
"Events processed in correct order" )
108
- .matches (list ->
109
- eventProcessingList .get (0 ).getEndTime ().isBefore (eventProcessingList .get (1 ).startTime ),
108
+ .matches (list -> eventExecutedBefore (0 , 1 ),
110
109
"Start time of event 2 is after end time of event 1" );
111
110
}
112
111
@@ -132,8 +131,7 @@ public void onlyLastEventIsScheduledIfMoreReceivedDuringAndExecution() {
132
131
.matches (list -> eventProcessingList .get (0 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("1" ) &&
133
132
eventProcessingList .get (1 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("3" ),
134
133
"Events processed in correct order" )
135
- .matches (list ->
136
- eventProcessingList .get (0 ).getEndTime ().isBefore (eventProcessingList .get (1 ).startTime ),
134
+ .matches (list -> eventExecutedBefore (0 , 1 ),
137
135
"Start time of event 2 is after end time of event 1" );
138
136
}
139
137
@@ -175,8 +173,7 @@ public void processesNewEventIfItIsReceivedAfterExecutionInError() {
175
173
.matches (list -> eventProcessingList .get (0 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("1" ) &&
176
174
eventProcessingList .get (1 ).getCustomResource ().getMetadata ().getResourceVersion ().equals ("2" ),
177
175
"Events processed in correct order" )
178
- .matches (list ->
179
- eventProcessingList .get (0 ).getEndTime ().isBefore (eventProcessingList .get (1 ).startTime ),
176
+ .matches (list -> eventExecutedBefore (0 , 1 ),
180
177
"Start time of event 2 is after end time of event 1" );
181
178
182
179
assertThat (eventProcessingList .get (0 ).getException ()).isNotNull ();
@@ -233,6 +230,11 @@ private Object exceptionInExecution(InvocationOnMock invocation) {
233
230
}
234
231
}
235
232
233
+ private boolean eventExecutedBefore (int event1Index , int event2Index ) {
234
+ return eventProcessingList .get (event1Index ).getEndTime ().isBefore (eventProcessingList .get (event2Index ).startTime ) ||
235
+ eventProcessingList .get (event1Index ).getEndTime ().equals (eventProcessingList .get (event2Index ).startTime );
236
+ }
237
+
236
238
private void waitMinimalTimeForExecution () {
237
239
waitTimeForExecution (1 );
238
240
}
0 commit comments