fix: use controller name instead of controller class name

Author: metacosm

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java

@@ -50,7 +50,7 @@ public <R extends CustomResource> void register(
         configuration = existing;
       }
       final var retry = GenericRetry.fromConfiguration(configuration.getRetryConfiguration());
-      final var targetNamespaces = configuration.getNamespaces().toArray(new String[] {});
+      final var targetNamespaces = configuration.getNamespaces().toArray(new String[]{});
       registerController(controller, configuration.watchAllNamespaces(), retry, targetNamespaces);
     }
   }
@@ -66,18 +66,16 @@ private <R extends CustomResource> void registerController(
     Class<R> resClass = configuration.getCustomResourceClass();
     String finalizer = configuration.getFinalizer();
     MixedOperation client = k8sClient.customResources(resClass);
-    EventDispatcher eventDispatcher =
-        new EventDispatcher(
-            controller, finalizer, new EventDispatcher.CustomResourceFacade(client));
+    EventDispatcher dispatcher = new EventDispatcher(controller, finalizer,
+        new EventDispatcher.CustomResourceFacade(client));
 
     CustomResourceCache customResourceCache = new CustomResourceCache();
     DefaultEventHandler defaultEventHandler =
-        new DefaultEventHandler(
-            customResourceCache, eventDispatcher, controller.getClass().getName(), retry);
+        new DefaultEventHandler(customResourceCache, dispatcher, configuration.getName(), retry);
     DefaultEventSourceManager eventSourceManager =
         new DefaultEventSourceManager(defaultEventHandler, retry != null);
     defaultEventHandler.setEventSourceManager(eventSourceManager);
-    eventDispatcher.setEventSourceManager(eventSourceManager);
+    dispatcher.setEventSourceManager(eventSourceManager);
 
     controller.init(eventSourceManager);
     CustomResourceEventSource customResourceEventSource =
@@ -111,7 +109,7 @@ private CustomResourceEventSource createCustomResourceEventSource(
     CustomResourceEventSource customResourceEventSource =
         watchAllNamespaces
             ? CustomResourceEventSource.customResourceEventSourceForAllNamespaces(
-                customResourceCache, client, generationAware, finalizer)
+            customResourceCache, client, generationAware, finalizer)
             : CustomResourceEventSource.customResourceEventSourceForTargetNamespaces(
                 customResourceCache, client, targetNamespaces, generationAware, finalizer);
 

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

@@ -17,7 +17,6 @@
 import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.locks.ReentrantLock;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -52,13 +51,7 @@ public DefaultEventHandler(
     eventBuffer = new EventBuffer();
     executor =
         new ScheduledThreadPoolExecutor(
-            5,
-            new ThreadFactory() {
-              @Override
-              public Thread newThread(Runnable runnable) {
-                return new Thread(runnable, "EventHandler-" + relatedControllerName);
-              }
-            });
+            5, runnable -> new Thread(runnable, "EventHandler-" + relatedControllerName));
   }
 
   public void setEventSourceManager(DefaultEventSourceManager eventSourceManager) {