feat: wrap registration errors in OperatorException

Author: metacosm

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

@@ -4,6 +4,7 @@
 import io.fabric8.kubernetes.client.CustomResource;
 import io.fabric8.kubernetes.client.dsl.MixedOperation;
 import io.fabric8.kubernetes.client.dsl.Resource;
+import io.javaoperatorsdk.operator.OperatorException;
 import io.javaoperatorsdk.operator.api.ResourceController;
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
 import io.javaoperatorsdk.operator.processing.CustomResourceCache;
@@ -69,7 +70,8 @@ public void close() {
   }
 
   @Override
-  public final void registerEventSource(String name, EventSource eventSource) {
+  public final void registerEventSource(String name, EventSource eventSource)
+      throws OperatorException {
     Objects.requireNonNull(eventSource, "EventSource must not be null");
 
     try {
@@ -81,6 +83,12 @@ public final void registerEventSource(String name, EventSource eventSource) {
       eventSources.put(name, eventSource);
       eventSource.setEventHandler(defaultEventHandler);
       eventSource.start();
+    } catch (Throwable e) {
+      if (e instanceof IllegalStateException) {
+        // leave untouched
+        throw e;
+      }
+      throw new OperatorException("Couldn't register event source named '" + name + "'", e);
     } finally {
       lock.unlock();
     }

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

@@ -1,5 +1,6 @@
 package io.javaoperatorsdk.operator.processing.event;
 
+import io.javaoperatorsdk.operator.OperatorException;
 import java.io.Closeable;
 import java.util.Map;
 import java.util.Optional;
@@ -13,8 +14,10 @@ public interface EventSourceManager extends Closeable {
    * @param eventSource the {@link EventSource} to register
    * @throws IllegalStateException if an {@link EventSource} with the same name is already
    *     registered.
+   * @throws OperatorException if an error occurred during the registration process
    */
-  void registerEventSource(String name, EventSource eventSource);
+  void registerEventSource(String name, EventSource eventSource)
+      throws IllegalStateException, OperatorException;
 
   /**
    * Remove the {@link EventSource} identified by the given <code>name</code> from the event