Move blocking readPair call to boundedElastic thread

apache · Jul 24, 2023 · dec0b5d · dec0b5d
1 parent aeb4710
commit dec0b5d
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...ssandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java b/...ssandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java
@@ -170,7 +170,16 @@ public Mono<MailboxCounters> getMailboxCountersReactive(Mailbox mailbox) {
                 }
                 return Mono.just(counters);
             })
-            .doOnNext(counters -> readRepair(mailbox, counters));
+            .doOnNext(counters -> {
+                if (this.cassandraConfiguration.getMailboxReadRepair() > 0) {
+                    Mono.fromRunnable(() -> {
+                        readRepair(mailbox, counters);
+                    })
+                   .subscribeOn(Schedulers.boundedElastic())
+                   .subscribe();
+                }
+            });
+
     }
 
     public Mono<MailboxCounters> readMailboxCounters(CassandraId mailboxId) {