fix(vertx): Fix wrong message for vertx eventbus (#839)

MartinWitt · Jul 14, 2023 · 5e9f3b3 · 5e9f3b3
1 parent 0722974
commit 5e9f3b3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 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,7 @@ 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().send(MiningStartup.SERVICE_NAME, storeResults.analyzerName());
+        vertx.eventBus().publish(MiningStartup.SERVICE_NAME, storeResults.analyzerName());
     }
 
     private AnalyzerStatus getAnalyzerStatus(CodeAnalyzerResult spoonResult, String name) {
@@ -83,6 +83,5 @@ private void addOrUpdateCommitHash(Project project, CodeAnalyzerResult spoonResu
             oldProject.addCommitHash(gitHubCommit);
             projectRepository.save(oldProject);
         }
-        vertx.eventBus().send(AnalyzerResultsPersistence.SERVICE_NAME, project);
     }
 }
diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/QodanaPeriodicMiner.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/QodanaPeriodicMiner.java
@@ -88,7 +88,7 @@ private void storeFailure(ProjectResult.Success success, QodanaResult.Failure er
         tryDeleteProject(success);
         StoreResults storeResults =
                 new StoreResults(success.project(), new CodeAnalyzerResult.Failure(error.message()), ANALYZER_NAME);
-        vertx.eventBus().send(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
+        vertx.eventBus().publish(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
     }
 
     private void storeSuccess(ProjectResult.Success success, QodanaResult.Success qodanaSuccess) {
@@ -97,6 +97,6 @@ private void storeSuccess(ProjectResult.Success success, QodanaResult.Success qo
                 success.project(),
                 new CodeAnalyzerResult.Success(qodanaSuccess.result(), success.project()),
                 ANALYZER_NAME);
-        vertx.eventBus().send(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
+        vertx.eventBus().publish(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
     }
 }
diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/SpoonPeriodicMiner.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/SpoonPeriodicMiner.java
@@ -87,7 +87,7 @@ private void storeFailure(ProjectResult.Success success, CodeAnalyzerResult.Fail
         tryDeleteProject(success);
         StoreResults storeResults =
                 new StoreResults(success.project(), new CodeAnalyzerResult.Failure(error.message()), ANALYZER_NAME);
-        vertx.eventBus().send(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
+        vertx.eventBus().publish(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
     }
 
     private void storeSuccess(ProjectResult.Success success, CodeAnalyzerResult.Success spoonSuccess) {
@@ -96,6 +96,6 @@ private void storeSuccess(ProjectResult.Success success, CodeAnalyzerResult.Succ
                 success.project(),
                 new CodeAnalyzerResult.Success(spoonSuccess.results(), success.project()),
                 ANALYZER_NAME);
-        vertx.eventBus().send(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
+        vertx.eventBus().publish(AnalyzerResultsPersistence.SERVICE_NAME, storeResults);
     }
 }