fix: [CI-8487]: unregistered ObserverEventConsumer in sto

Author: devkimittal

315-sto-manager/app/src/main/java/io/harness/app/STOManagerApplication.java

@@ -12,7 +12,6 @@
 import static io.harness.app.STOManagerConfiguration.NG_PIPELINE_PACKAGE;
 import static io.harness.authorization.AuthorizationServiceHeader.STO_MANAGER;
 import static io.harness.data.structure.EmptyPredicate.isNotEmpty;
-import static io.harness.eventsframework.EventsFrameworkConstants.OBSERVER_EVENT_CHANNEL;
 import static io.harness.logging.LoggingInitializer.initializeLogging;
 import static io.harness.pms.contracts.plan.ExpansionRequestType.KEY;
 import static io.harness.pms.listener.NgOrchestrationNotifyEventListener.NG_ORCHESTRATION;
@@ -27,7 +26,6 @@
 import io.harness.app.telemetry.STOTelemetryRecordsJob;
 import io.harness.authorization.AuthorizationServiceHeader;
 import io.harness.cache.CacheModule;
-import io.harness.ci.execution.ObserverEventConsumer;
 import io.harness.ci.execution.OrchestrationExecutionEventHandlerRegistrar;
 import io.harness.ci.execution.queue.CIExecutionPoller;
 import io.harness.ci.plan.creator.CIModuleInfoProvider;
@@ -111,7 +109,6 @@
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
-import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.google.inject.AbstractModule;
 import com.google.inject.Guice;
 import com.google.inject.Injector;
@@ -141,8 +138,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.function.Predicate;
@@ -319,7 +314,6 @@ public boolean isNotPrimary() {
     scheduleJobs(injector, configuration);
     registerQueueListener(injector);
     registerPmsSdkEvents(injector);
-    registerEventConsumers(injector);
     registerExceptionMappers(environment);
 
     if (BooleanUtils.isTrue(configuration.getEnableOpentelemetry())) {
@@ -344,12 +338,6 @@ public static Collection<Class<?>> getResourceClasses() {
     return classSet;
   }
 
-  private void registerEventConsumers(final Injector injector) {
-    final ExecutorService entityCRUDConsumerExecutor =
-        Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat(OBSERVER_EVENT_CHANNEL).build());
-    entityCRUDConsumerExecutor.execute(injector.getInstance(ObserverEventConsumer.class));
-  }
-
   private void registerOasResource(CIManagerConfiguration appConfig, Environment environment, Injector injector) {
     OpenApiResource openApiResource = injector.getInstance(OpenApiResource.class);
     openApiResource.setOpenApiConfiguration(