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

Reply via email to