From 050f0d9b072ea2732f9303ab912ac9efd588fa46 Mon Sep 17 00:00:00 2001
From: YevhenBondarenko <ybondarenko@thingsboard.io>
Date: Thu, 15 Jul 2021 20:35:13 +0300
Subject: [PATCH] fixed duplicated read/observe requests

---
 .../lwm2m/server/uplink/DefaultLwM2MUplinkMsgHandler.java        | 1 +
 1 file changed, 1 insertion(+)

diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/uplink/DefaultLwM2MUplinkMsgHandler.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/uplink/DefaultLwM2MUplinkMsgHandler.java
index 257fff72eb..26e457de17 100644
--- a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/uplink/DefaultLwM2MUplinkMsgHandler.java
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/uplink/DefaultLwM2MUplinkMsgHandler.java
@@ -422,6 +422,7 @@ public class DefaultLwM2MUplinkMsgHandler extends LwM2MExecutorAwareService impl
     private void sendReadRequests(LwM2mClient lwM2MClient, Lwm2mDeviceProfileTransportConfiguration profile, Set<String> supportedObjects) {
         Set<String> targetIds = new HashSet<>(profile.getObserveAttr().getAttribute());
         targetIds.addAll(profile.getObserveAttr().getTelemetry());
+        targetIds = diffSets(targetIds, profile.getObserveAttr().getObserve());
         targetIds = targetIds.stream().filter(target -> isSupportedTargetId(supportedObjects, target)).collect(Collectors.toSet());
 
         CountDownLatch latch = new CountDownLatch(targetIds.size());