From 59fa19d1c861d10aca3a44073a1786c10aab0d9c Mon Sep 17 00:00:00 2001 From: ViacheslavKlimov Date: Thu, 10 Apr 2025 11:40:19 +0300 Subject: [PATCH] Change EDQS consumers poll interval from 125 ms to 25 ms --- application/src/main/resources/thingsboard.yml | 2 +- .../main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java | 2 +- edqs/src/main/resources/edqs.yml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/application/src/main/resources/thingsboard.yml b/application/src/main/resources/thingsboard.yml index b4d178a737..42f5331e21 100644 --- a/application/src/main/resources/thingsboard.yml +++ b/application/src/main/resources/thingsboard.yml @@ -1773,7 +1773,7 @@ queue: # EDQS responses topic responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}" # Poll interval for EDQS topics - poll_interval: "${TB_EDQS_POLL_INTERVAL_MS:125}" + poll_interval: "${TB_EDQS_POLL_INTERVAL_MS:25}" # Maximum amount of pending requests to EDQS max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}" # Maximum timeout for requests to EDQS diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java b/common/queue/src/main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java index 401b451f59..3c927f135b 100644 --- a/common/queue/src/main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java +++ b/common/queue/src/main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java @@ -38,7 +38,7 @@ public class EdqsConfig { private String requestsTopic; @Value("${queue.edqs.responses_topic:edqs.responses}") private String responsesTopic; - @Value("${queue.edqs.poll_interval:125}") + @Value("${queue.edqs.poll_interval:25}") private long pollInterval; @Value("${queue.edqs.max_pending_requests:10000}") private int maxPendingRequests; diff --git a/edqs/src/main/resources/edqs.yml b/edqs/src/main/resources/edqs.yml index 2c0e0b8c5d..8ea40c03c8 100644 --- a/edqs/src/main/resources/edqs.yml +++ b/edqs/src/main/resources/edqs.yml @@ -66,7 +66,7 @@ queue: # EDQS responses topic responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}" # Poll interval for EDQS topics - poll_interval: "${TB_EDQS_POLL_INTERVAL_MS:125}" + poll_interval: "${TB_EDQS_POLL_INTERVAL_MS:25}" # Maximum amount of pending requests to EDQS max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}" # Maximum timeout for requests to EDQS