fix(vertx): Fix duplication of vertx events

MartinWitt · Jul 15, 2023 · b247909 · b247909
1 parent 27ab435
commit b247909
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.../src/main/java/io/github/martinwitt/laughing_train/mining/AnalyzerResultsPersistence.java b/.../src/main/java/io/github/martinwitt/laughing_train/mining/AnalyzerResultsPersistence.java
@@ -41,7 +41,6 @@ void persistResults(StoreResults storeResults) {
         } else if (result instanceof CodeAnalyzerResult.Success success) {
             logger.atInfo().log("Analyzer %s succeeded for project %s", storeResults.analyzerName(), project.name());
         }
-        vertx.eventBus().publish(MiningStartup.SERVICE_NAME, storeResults.analyzerName());
     }
 
     private AnalyzerStatus getAnalyzerStatus(CodeAnalyzerResult spoonResult, String name) {

diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/MiningStartup.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/MiningStartup.java
@@ -42,8 +42,9 @@ void startup(@Observes StartupEvent event) {
                         vertx.deployVerticle(qodanaPeriodicMiner, options),
                         vertx.deployVerticle(spoonPeriodicMiner, options),
                         vertx.deployVerticle(persistence, options),
-                        vertx.deployVerticle(projectSupplier, options),
-                        vertx.deployVerticle(miningEventConsumer, options))
+                        vertx.deployVerticle(projectSupplier, options)
+                        // vertx.deployVerticle(miningEventConsumer, options)
+                        )
                 .onFailure(Throwable::printStackTrace)
                 .onComplete(v -> System.out.println("All verticles deployed"))
                 .onSuccess(v -> startMining());