This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 8ac55b31482c71e92a302a0ed826913b7d1dd2a1 Author: Benoit TELLIER <btell...@linagora.com> AuthorDate: Sun Nov 10 12:50:42 2024 +0100 [FIX] Handle IMAP IDLE logs --- .../main/java/org/apache/james/imap/processor/IdleProcessor.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java index f83707bb7f..570a67120d 100644 --- a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java +++ b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdleProcessor.java @@ -20,6 +20,7 @@ package org.apache.james.imap.processor; import static org.apache.james.imap.api.ImapConstants.SUPPORTS_IDLE; +import static org.apache.james.util.ReactorUtils.logAsMono; import java.time.Duration; import java.util.List; @@ -80,7 +81,11 @@ public class IdleProcessor extends AbstractMailboxProcessor<IdleRequest> impleme @Override protected Mono<Void> processRequestReactive(IdleRequest request, ImapSession session, Responder responder) { return Mono.fromRunnable(() -> idle(request,session, responder)) - .then(unsolicitedResponses(session, responder, false)); + .then(unsolicitedResponses(session, responder, false)) + .onErrorResume(e -> { + no(request, responder, HumanReadableText.GENERIC_FAILURE_DURING_PROCESSING); + return logAsMono(() -> LOGGER.error("Encountered error executing IMAP IDLE", e)); + }); } private void idle(IdleRequest request, ImapSession session, Responder responder) { --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org For additional commands, e-mail: notifications-h...@james.apache.org