You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2022/07/28 02:44:07 UTC
[james-project] 04/05: JAMES-3784 EmptyErrorMailRepositoryHealthCheck support sizeReactive
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 5a6d4e32215fa1a24c6a02c87fe9bc9aa6b842d9
Author: Tung Van TRAN <vt...@linagora.com>
AuthorDate: Wed Jun 29 10:47:10 2022 +0700
JAMES-3784 EmptyErrorMailRepositoryHealthCheck support sizeReactive
---
.../james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/mailrepository/mailrepository-api/src/main/java/org/apache/james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java b/server/mailrepository/mailrepository-api/src/main/java/org/apache/james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java
index dd8752b0ca..f699a25bbf 100644
--- a/server/mailrepository/mailrepository-api/src/main/java/org/apache/james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java
+++ b/server/mailrepository/mailrepository-api/src/main/java/org/apache/james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java
@@ -46,9 +46,9 @@ public class EmptyErrorMailRepositoryHealthCheck implements HealthCheck {
@Override
public Mono<Result> check() {
- // TODO: use .sizeReactive of https://github.com/apache/james-project/pull/1049/
return Flux.fromStream(Throwing.supplier(() -> repositoryStore.getByPath(errorRepositoryPath)))
- .any(Throwing.predicate(repository -> repository.size() > 0))
+ .flatMap(MailRepository::sizeReactive)
+ .any(repositorySize -> repositorySize > 0)
.filter(FunctionalUtils.identityPredicate())
.map(hasSize -> Result.degraded(COMPONENT_NAME, "MailRepository is not empty"))
.switchIfEmpty(Mono.just(Result.healthy(COMPONENT_NAME)));
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org