fix_bug: lwm2mClient registration log.warn

application/src/test/java/org/thingsboard/server/transport/lwm2m/rpc/sql/RpcLwm2mIntegrationObserveTest.java

@@ -167,18 +167,18 @@ public class RpcLwm2mIntegrationObserveTest extends AbstractRpcLwM2MIntegrationT
      */
     @Test
     public void testObserveReadAll_Result_CONTENT_Value_Contains_Paths_Count_ObserveReadAll() throws Exception {
+        String idVer_3_0_0 = objectInstanceIdVer_3 + "/" + RESOURCE_ID_0;
+        sendObserve("Observe", fromVersionedIdToObjectId(idVer_3_0_0));
         String actualResultCancel = sendObserve("ObserveCancelAll", null);
         ObjectNode rpcActualResultCancel = JacksonUtil.fromString(actualResultCancel, ObjectNode.class);
         assertEquals(ResponseCode.CONTENT.getName(), rpcActualResultCancel.get("result").asText());
-        sendObserve("Observe",idVer_19_0_0);
-        sendObserve("Observe", idVer_3_0_9);
+        sendObserve("Observe", fromVersionedIdToObjectId(idVer_3_0_0));
         String actualResult = sendObserve("ObserveReadAll", null);
         ObjectNode rpcActualResult = JacksonUtil.fromString(actualResult, ObjectNode.class);
         assertEquals(ResponseCode.CONTENT.getName(), rpcActualResult.get("result").asText());
         String actualValues = rpcActualResult.get("value").asText();
-        assertTrue(actualValues.contains(fromVersionedIdToObjectId(idVer_19_0_0)));
-        assertTrue(actualValues.contains(fromVersionedIdToObjectId(idVer_3_0_9)));
-        assertEquals(2, actualValues.split(",").length);
+        assertTrue(actualValues.contains(fromVersionedIdToObjectId(idVer_3_0_0)));
+        assertEquals(1, actualValues.split(",").length);
     }
 
 

common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/LwM2mServerListener.java

@@ -52,6 +52,7 @@ public class LwM2mServerListener {
         @Override
         public void registered(Registration registration, Registration previousReg,
                                Collection<Observation> previousObservations) {
+            log.warn("Client: registered: [{}]", registration.getEndpoint());
             service.onRegistered(registration, previousObservations);
         }
 

common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/uplink/DefaultLwM2mUplinkMsgHandler.java

@@ -216,7 +216,7 @@ public class DefaultLwM2mUplinkMsgHandler extends LwM2MExecutorAwareService impl
         executor.submit(() -> {
             LwM2mClient lwM2MClient = this.clientContext.getClientByEndpoint(registration.getEndpoint());
             try {
-                log.debug("[{}] [{{}] Client: create after Registration", registration.getEndpoint(), registration.getId());
+                log.warn("[{}] [{{}] Client: create after Registration", registration.getEndpoint(), registration.getId());
                 Optional<SessionInfoProto> oldSessionInfo = this.clientContext.register(lwM2MClient, registration);
                 if (oldSessionInfo.isPresent()) {
                     log.info("[{}] Closing old session: {}", registration.getEndpoint(), new UUID(oldSessionInfo.get().getSessionIdMSB(), oldSessionInfo.get().getSessionIdLSB()));