diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java index 04ed2cab132..d594347111a 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java @@ -170,7 +170,16 @@ public Mono 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 readMailboxCounters(CassandraId mailboxId) {