From 1dc47b5cc56f1f10e0ce7c3f0d2b60e34b83393c Mon Sep 17 00:00:00 2001 From: Igor Kulikov Date: Mon, 15 Mar 2021 19:29:40 +0200 Subject: [PATCH] Revert interval check for telemetry subscription --- .../subscription/DefaultSubscriptionManagerService.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/application/src/main/java/org/thingsboard/server/service/subscription/DefaultSubscriptionManagerService.java b/application/src/main/java/org/thingsboard/server/service/subscription/DefaultSubscriptionManagerService.java index b73641e9ad..844db92de8 100644 --- a/application/src/main/java/org/thingsboard/server/service/subscription/DefaultSubscriptionManagerService.java +++ b/application/src/main/java/org/thingsboard/server/service/subscription/DefaultSubscriptionManagerService.java @@ -434,9 +434,7 @@ public class DefaultSubscriptionManagerService extends TbApplicationEventListene if (curTs > value) { long startTs = subscription.getStartTime() > 0 ? Math.max(subscription.getStartTime(), value + 1L) : (value + 1L); long endTs = subscription.getEndTime() > 0 ? Math.min(subscription.getEndTime(), curTs) : curTs; - if (startTs > 1) { - queries.add(new BaseReadTsKvQuery(key, startTs, endTs, 0, 1000, Aggregation.NONE)); - } + queries.add(new BaseReadTsKvQuery(key, startTs, endTs, 0, 1000, Aggregation.NONE)); } }); if (!queries.isEmpty()) {