fix(rules): add blocking annotation for rules error (backport #526) (#…

…532) fix(rules): add blocking annotation for rules error (#526) (cherry picked from commit 0914b94) Co-authored-by: Ming Yu Wang <[email protected]>
cryostatio · Jun 24, 2024 · 1956823 · 1956823
1 parent 700a42f
commit 1956823
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/cryostat/rules/RuleService.java b/src/main/java/io/cryostat/rules/RuleService.java
@@ -84,7 +84,7 @@ void onStart(@Observes StartupEvent ev) {
         Rule.<Rule>streamAll().filter(r -> r.enabled).forEach(this::applyRuleToMatchingTargets);
     }
 
-    @ConsumeEvent(value = Target.TARGET_JVM_DISCOVERY)
+    @ConsumeEvent(value = Target.TARGET_JVM_DISCOVERY, blocking = true)
     void onMessage(TargetDiscovery event) {
         switch (event.kind()) {
             case FOUND: