@@ -86,13 +86,13 @@ void scheduleEvent(CustomResourceEvent event) {
86
86
if (eventStore .containsNotScheduledEvent (event .resourceUid ())) {
87
87
log .debug ("Replacing not scheduled event with actual event." +
88
88
" New event: {}" , event );
89
- eventStore .addOrReplaceEventAsNotScheduledYet (event );
89
+ eventStore .addOrReplaceEventAsNotScheduled (event );
90
90
return ;
91
91
}
92
92
if (eventStore .containsEventUnderProcessing (event .resourceUid ())) {
93
93
log .debug ("Scheduling event for later processing since there is an event under processing for same kind." +
94
94
" New event: {}" , event );
95
- eventStore .addOrReplaceEventAsNotScheduledYet (event );
95
+ eventStore .addOrReplaceEventAsNotScheduled (event );
96
96
return ;
97
97
}
98
98
@@ -118,7 +118,7 @@ void eventProcessingFinishedSuccessfully(CustomResourceEvent event) {
118
118
eventStore .removeEventUnderProcessing (event .resourceUid ());
119
119
if (eventStore .containsNotScheduledEvent (event .resourceUid ())) {
120
120
log .debug ("Scheduling recent event for processing processing: {}" , event );
121
- scheduleEvent (eventStore .removeEventNotScheduledYet (event .resourceUid ()));
121
+ scheduleEvent (eventStore .removeEventNotScheduled (event .resourceUid ()));
122
122
}
123
123
} finally {
124
124
lock .unlock ();
@@ -130,7 +130,7 @@ void eventProcessingFailed(CustomResourceEvent event) {
130
130
lock .lock ();
131
131
eventStore .removeEventUnderProcessing (event .resourceUid ());
132
132
if (eventStore .containsNotScheduledEvent (event .resourceUid ())) {
133
- CustomResourceEvent notScheduledEvent = eventStore .removeEventNotScheduledYet (event .resourceUid ());
133
+ CustomResourceEvent notScheduledEvent = eventStore .removeEventNotScheduled (event .resourceUid ());
134
134
log .debug ("Event processing failed. Scheduling the most recent event. Failed event: {}," +
135
135
" Most recent event: {}" , event , notScheduledEvent );
136
136
scheduleEvent (notScheduledEvent );
0 commit comments