Run profile inactivity timeout propagation synchronously

5 months ago · 77d165dea6
1 changed files with 2 additions and 2 deletions
--- a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java
+++ b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java
@ -376,7 +376,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
        if (previousResolved != null && previousResolved == resolvedNew) {
            return;
        }
-        deviceStateCallbackExecutor.submit(() -> deviceStates.forEach((deviceId, stateData) -> {
+        deviceStates.forEach((deviceId, stateData) -> {
            if (!profileId.equals(stateData.getDeviceProfileId())) {
                return;
            }
@ -388,7 +388,7 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
            }
            stateData.getState().setInactivityTimeout(resolvedNew);
            checkAndUpdateState(deviceId, stateData);
-        }));
+        });
    }

    @Override