wip

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

@@ -38,7 +38,9 @@ public class EventSourceManager<P extends HasMetadata>
   private final ExecutorServiceManager executorServiceManager;
 
   public EventSourceManager(Controller<P> controller) {
-    this(controller, new EventSources<>());
+    this(
+        controller,
+        new EventSources<>(controller.getConfiguration().triggerReconcilerOnAllEvent()));
   }
 
   EventSourceManager(Controller<P> controller, EventSources<P> eventSources) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSources.java

@@ -22,12 +22,16 @@ class EventSources<P extends HasMetadata> {
       new ConcurrentSkipListMap<>();
   private final Map<String, EventSource> sourceByName = new HashMap<>();
 
-  private final TimerEventSource<P> retryAndRescheduleTimerEventSource =
-      new TimerEventSource<>("RetryAndRescheduleTimerEventSource");
+  private final TimerEventSource<P> retryAndRescheduleTimerEventSource;
   private ControllerEventSource<P> controllerEventSource;
 
   public EventSources(boolean triggerReconcilerOnAllEvent) {
-    this.controllerEventSource = controllerEventSource;
+    retryAndRescheduleTimerEventSource =
+        new TimerEventSource<>("RetryAndRescheduleTimerEventSource", triggerReconcilerOnAllEvent);
+  }
+
+  EventSources() {
+    this(false);
   }
 
   public void add(EventSource eventSource) {

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/ReconciliationDispatcherTest.java

@@ -710,7 +710,7 @@ void reconcilerContextUsesTheSameInstanceOfResourceAsParam() {
   }
 
   @Test
-  void allEventModeNoReSchedulesAllowedForDeleteEvent() {}
+  void procAllEventModeNoReSchedulesAllowedForDeleteEvent() {}
 
   private ObservedGenCustomResource createObservedGenCustomResource() {
     ObservedGenCustomResource observedGenCustomResource = new ObservedGenCustomResource();