Move blocking readPair call to boundedElastic thread

apache · Jul 23, 2023 · d2c426a · d2c426a
1 parent aeb4710
commit d2c426a
Showing 1 changed file with 8 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,14 @@ public Mono<MailboxCounters> getMailboxCountersReactive(Mailbox mailbox) {
                 }
                 return Mono.just(counters);
             })
-            .doOnNext(counters -> readRepair(mailbox, counters));
+            .doOnNext(counters -> {
+                Mono.fromRunnable(() -> {
+                    readRepair(mailbox, counters);
+                })
+               .subscribeOn(Schedulers.boundedElastic())
+               .subscribe();
+            });
+
     }
 
     public Mono<MailboxCounters> readMailboxCounters(CassandraId mailboxId) {