Fixed comp error

thingsboard · Nov 2, 2023 · 8594988 · 8594988
1 parent a816b20
commit 8594988
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../main/java/org/thingsboard/server/service/cloud/rpc/processor/ResourceCloudProcessor.java b/.../main/java/org/thingsboard/server/service/cloud/rpc/processor/ResourceCloudProcessor.java
@@ -40,7 +40,7 @@ public class ResourceCloudProcessor extends BaseResourceProcessor {
     public ListenableFuture<Void> processResourceMsgFromCloud(TenantId tenantId, ResourceUpdateMsg resourceUpdateMsg) {
         TbResourceId tbResourceId = new TbResourceId(new UUID(resourceUpdateMsg.getIdMSB(), resourceUpdateMsg.getIdLSB()));
         try {
-            edgeSynchronizationManager.getSync().set(true);
+            cloudSynchronizationManager.getSync().set(true);
             switch (resourceUpdateMsg.getMsgType()) {
                 case ENTITY_CREATED_RPC_MESSAGE:
                 case ENTITY_UPDATED_RPC_MESSAGE:
@@ -57,7 +57,7 @@ public ListenableFuture<Void> processResourceMsgFromCloud(TenantId tenantId, Res
                     return handleUnsupportedMsgType(resourceUpdateMsg.getMsgType());
             }
         } finally {
-            edgeSynchronizationManager.getSync().remove();
+            cloudSynchronizationManager.getSync().remove();
         }
         return Futures.immediateFuture(null);
     }