fix(vertx): Fix event duplication during spoon mining

MartinWitt · Jul 15, 2023 · 27ab435 · 27ab435
1 parent c9c9811
commit 27ab435
Showing 1 changed file with 8 additions and 2 deletions.
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
@@ -1,7 +1,6 @@
 package io.github.martinwitt.laughing_train.mining;
 
 import io.github.martinwitt.laughing_train.mining.requests.MineNextProject;
-import io.quarkus.logging.Log;
 import io.quarkus.runtime.StartupEvent;
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.DeploymentOptions;
@@ -47,13 +46,20 @@ void startup(@Observes StartupEvent event) {
                         vertx.deployVerticle(miningEventConsumer, options))
                 .onFailure(Throwable::printStackTrace)
                 .onComplete(v -> System.out.println("All verticles deployed"))
-                .onSuccess(v -> Log.info("Starting periodic mining"));
+                .onSuccess(v -> startMining());
         vertx.eventBus().addInboundInterceptor(v -> {
             System.out.println("Received message: " + v.toString());
             v.next();
         });
     }
 
+    private void startMining() {
+        vertx.setPeriodic(TimeUnit.MINUTES.toMillis(3), TimeUnit.MINUTES.toMillis(25), v -> vertx.eventBus()
+                .publish("miner", new MineNextProject(QodanaPeriodicMiner.ANALYZER_NAME)));
+        vertx.setPeriodic(TimeUnit.MINUTES.toMillis(2), TimeUnit.MINUTES.toMillis(10), v -> vertx.eventBus()
+                .publish("miner", new MineNextProject(SpoonPeriodicMiner.ANALYZER_NAME)));
+    }
+
     @ApplicationScoped
     private static class MiningEventConsumer extends AbstractVerticle {