Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

设备心跳

Browse Source
This commit is contained in:
shikong 2023-09-13 15:46:53 +08:00
parent ee9b8ce08c
commit 2c973673d0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/gb28181/keepalive/KeepaliveService.java
View File

@ -24,7 +24,7 @@ public class KeepaliveService {
public void keepalive(MockingDevice mockingDevice){ public void keepalive(MockingDevice mockingDevice){
unKeepalive(mockingDevice); unKeepalive(mockingDevice);
scheduledExecutorService.scheduleWithFixedDelay(()->{ ScheduledFuture<?> scheduledFuture = scheduledExecutorService.scheduleWithFixedDelay(() -> {
KeepaliveNotifyDTO keepaliveNotifyDTO = KeepaliveNotifyDTO.builder() KeepaliveNotifyDTO keepaliveNotifyDTO = KeepaliveNotifyDTO.builder()
.deviceId(mockingDevice.getGbDeviceId()) .deviceId(mockingDevice.getGbDeviceId())
.sn(String.valueOf((int) ((Math.random() * 9 + 1) * 100000))) .sn(String.valueOf((int) ((Math.random() * 9 + 1) * 100000)))
@ -41,6 +41,7 @@ public class KeepaliveService {
callIdHeader); callIdHeader);
}); });
}, 0, 30, TimeUnit.SECONDS); }, 0, 30, TimeUnit.SECONDS);
map.put(mockingDevice.getGbDeviceId(), scheduledFuture);
} }
public void unKeepalive(MockingDevice mockingDevice){ public void unKeepalive(MockingDevice mockingDevice){