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
The following commit(s) were added to refs/heads/master by this push:
new c07d393b35 [FIX] FetchProcessor: only log Resuming IMAP FETCH once
(#2217)
c07d393b35 is described below
commit c07d393b353f3aef088d8710087a3a5492e97659
Author: Benoit TELLIER <btell...@linagora.com>
AuthorDate: Mon Apr 29 14:30:59 2024 +0200
[FIX] FetchProcessor: only log Resuming IMAP FETCH once (#2217)
The log mistakenly lead to think backpressure was restored multiple time
---
.../main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
b/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
index 90291cae84..800c036e14 100644
---
a/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
+++
b/protocols/imap/src/main/java/org/apache/james/imap/processor/fetch/FetchProcessor.java
@@ -99,8 +99,8 @@ public class FetchProcessor extends
AbstractMailboxProcessor<FetchRequest> {
AtomicBoolean mustRequestOne = new AtomicBoolean(true);
responder.respond(fetchResponse);
Runnable requestOne = () -> {
- LOGGER.info("Resuming IMAP FETCH for user {}",
imapSession.getUserName().asString());
if (mustRequestOne.getAndSet(false)) {
+ LOGGER.info("Resuming IMAP FETCH for user {}",
imapSession.getUserName().asString());
requestOne();
}
};
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org
