handle events in ordered serial fashion

cryostatio · Nov 25, 2024 · 9caa89a · 9caa89a
1 parent 1d372f3
commit 9caa89a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/io/cryostat/rules/RuleService.java b/src/main/java/io/cryostat/rules/RuleService.java
@@ -92,7 +92,7 @@ void onStop(@Observes ShutdownEvent evt) throws SchedulerException {
         quartz.shutdown();
     }
 
-    @ConsumeEvent(value = Target.TARGET_JVM_DISCOVERY, blocking = true)
+    @ConsumeEvent(value = Target.TARGET_JVM_DISCOVERY, blocking = true, ordered = true)
     void onMessage(TargetDiscovery event) {
         switch (event.kind()) {
             case MODIFIED:
@@ -123,7 +123,7 @@ void onMessage(TargetDiscovery event) {
         }
     }
 
-    @ConsumeEvent(value = Rule.RULE_ADDRESS, blocking = true)
+    @ConsumeEvent(value = Rule.RULE_ADDRESS, blocking = true, ordered = true)
     @Transactional
     public void handleRuleModification(RuleEvent event) {
         Rule rule = event.rule();
@@ -148,7 +148,7 @@ public void handleRuleModification(RuleEvent event) {
         }
     }
 
-    @ConsumeEvent(value = Rule.RULE_ADDRESS + "?clean", blocking = true)
+    @ConsumeEvent(value = Rule.RULE_ADDRESS + "?clean", blocking = true, ordered = true)
     @Transactional
     public void handleRuleRecordingCleanup(Rule rule) {
         cancelTasksForRule(rule);