unit test

Author: csviri

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

@@ -98,10 +98,6 @@ private EventProcessor(
     this.eventSourceManager = eventSourceManager;
   }
 
-  EventMarker getEventMarker() {
-    return eventMarker;
-  }
-
   @Override
   public void handleEvent(Event event) {
     lock.lock();

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

@@ -31,17 +31,6 @@ public class EventSourceManager<R extends HasMetadata> implements LifecycleAware
   private final EventProcessor<R> eventProcessor;
   private final Controller<R> controller;
 
-  EventSourceManager(EventProcessor<R> eventProcessor) {
-    this(eventProcessor, new EventSources<>());
-  }
-
-  EventSourceManager(EventProcessor<R> eventProcessor, EventSources<R> eventSources) {
-    this.eventProcessor = eventProcessor;
-    this.eventSources = new EventSources<>();
-    controller = null;
-    registerEventSource(eventSources.retryEventSource());
-  }
-
   public EventSourceManager(Controller<R> controller) {
     this(controller, new EventSources<>());
   }

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

@@ -29,7 +29,7 @@
 class EventSourceManagerTest {
 
   private final EventProcessor eventProcessor = mock(EventProcessor.class);
-  private final EventSourceManager eventSourceManager = new EventSourceManager(eventProcessor);
+  private final EventSourceManager eventSourceManager = initManager();
 
   @Test
   public void registersEventSource() {