You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2025/11/25 06:22:15 UTC
(james-project) 34/34: JAMES-3816 Record also concurrent IMAP request count
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 <bt...@linagora.com>
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: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org