@@ -114,10 +114,10 @@ void scheduleEvent(CustomResourceEvent event) {
114
114
void eventProcessingFinishedSuccessfully (CustomResourceEvent event ) {
115
115
try {
116
116
lock .lock ();
117
- log .debug ("Even processing successful for event: {}" , event );
117
+ log .debug ("Event processing successful for event: {}" , event );
118
118
eventStore .removeEventUnderProcessing (event .resourceUid ());
119
119
if (eventStore .containsNotScheduledEvent (event .resourceUid ())) {
120
- log .debug ("Scheduling not yet scheduled after previous successful processing: {}" , event );
120
+ log .debug ("Scheduling recent event for processing processing: {}" , event );
121
121
scheduleEvent (eventStore .removeEventNotScheduledYet (event .resourceUid ()));
122
122
}
123
123
} finally {
@@ -131,11 +131,11 @@ void eventProcessingFailed(CustomResourceEvent event) {
131
131
eventStore .removeEventUnderProcessing (event .resourceUid ());
132
132
if (eventStore .containsNotScheduledEvent (event .resourceUid ())) {
133
133
CustomResourceEvent notScheduledEvent = eventStore .removeEventNotScheduledYet (event .resourceUid ());
134
- log .debug ("Even processing failed. Scheduling the most recent event. Failed event: {}," +
134
+ log .debug ("Event processing failed. Scheduling the most recent event. Failed event: {}," +
135
135
" Most recent event: {}" , event , notScheduledEvent );
136
136
scheduleEvent (notScheduledEvent );
137
137
} else {
138
- log .debug ("Even processing failed. Attempting to re-schedule the event: {}" , event );
138
+ log .debug ("Event processing failed. Attempting to re-schedule the event: {}" , event );
139
139
scheduleEvent (event );
140
140
}
141
141
} finally {
0 commit comments