This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch 3.9.x in repository https://gitbox.apache.org/repos/asf/james-project.git
commit f49414a0faf05dce89365febb29b967ccfef79cd Author: Benoit TELLIER <[email protected]> AuthorDate: Thu Oct 2 23:19:11 2025 +0200 JAMES-3816 Record also concurrent IMAP request count --- .../main/java/org/apache/james/imapserver/netty/ReactiveThrottler.java | 1 + 1 file changed, 1 insertion(+) diff --git a/server/protocols/protocols-imap4/src/main/java/org/apache/james/imapserver/netty/ReactiveThrottler.java b/server/protocols/protocols-imap4/src/main/java/org/apache/james/imapserver/netty/ReactiveThrottler.java index 85f5bb5797..8d5dd196a0 100644 --- a/server/protocols/protocols-imap4/src/main/java/org/apache/james/imapserver/netty/ReactiveThrottler.java +++ b/server/protocols/protocols-imap4/src/main/java/org/apache/james/imapserver/netty/ReactiveThrottler.java @@ -78,6 +78,7 @@ public class ReactiveThrottler { public ReactiveThrottler(GaugeRegistry gaugeRegistry, int maxConcurrentRequests, int maxQueueSize) { gaugeRegistry.register("imap.request.queue.size", () -> Math.max(concurrentRequests.get() - maxConcurrentRequests, 0)); + gaugeRegistry.register("imap.request.concurrent.count", concurrentRequests::get); this.maxConcurrentRequests = maxConcurrentRequests; this.maxQueueSize = maxQueueSize; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
