dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change EDQS consumers poll interval from 125 ms to 25 ms

Browse Source
This commit is contained in:
ViacheslavKlimov 2025-04-10 11:40:19 +03:00
parent e8eef3a7df
commit 59fa19d1c8
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
application/src/main/resources/thingsboard.yml
View File

@ -1773,7 +1773,7 @@ queue:
# EDQS responses topic # EDQS responses topic
responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}" responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}"
# Poll interval for EDQS topics # 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 # Maximum amount of pending requests to EDQS
max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}" max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}"
# Maximum timeout for requests to EDQS # Maximum timeout for requests to EDQS

2
common/queue/src/main/java/org/thingsboard/server/queue/edqs/EdqsConfig.java
View File

@ -38,7 +38,7 @@ public class EdqsConfig {
private String requestsTopic; private String requestsTopic;
@Value("${queue.edqs.responses_topic:edqs.responses}") @Value("${queue.edqs.responses_topic:edqs.responses}")
private String responsesTopic; private String responsesTopic;
@Value("${queue.edqs.poll_interval:125}") @Value("${queue.edqs.poll_interval:25}")
private long pollInterval; private long pollInterval;
@Value("${queue.edqs.max_pending_requests:10000}") @Value("${queue.edqs.max_pending_requests:10000}")
private int maxPendingRequests; private int maxPendingRequests;

2
edqs/src/main/resources/edqs.yml
View File

@ -66,7 +66,7 @@ queue:
# EDQS responses topic # EDQS responses topic
responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}" responses_topic: "${TB_EDQS_RESPONSES_TOPIC:edqs.responses}"
# Poll interval for EDQS topics # 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 # Maximum amount of pending requests to EDQS
max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}" max_pending_requests: "${TB_EDQS_MAX_PENDING_REQUESTS:10000}"
# Maximum timeout for requests to EDQS # Maximum timeout for requests to EDQS