guoshilong
2023-10-23 dd73bbc7132f7b126b8fc2faabf2827b49622d21
src/main/java/com/dji/sample/component/ApplicationBootInitial.java
@@ -18,9 +18,6 @@
    @Autowired
    private IDeviceService deviceService;
    @Autowired
    private RedisOpsUtils redisOps;
    /**
     * Subscribe to the devices that exist in the redis when the program starts,
     * to prevent the data from being different from the pilot side due to program interruptions.
@@ -31,7 +28,7 @@
    public void run(String... args) throws Exception {
        int start = RedisConst.DEVICE_ONLINE_PREFIX.length();
        redisOps.getAllKeys(RedisConst.DEVICE_ONLINE_PREFIX + "*")
        RedisOpsUtils.getAllKeys(RedisConst.DEVICE_ONLINE_PREFIX + "*")
                .forEach(key -> deviceService.subscribeTopicOnline(key.substring(start)));
    }