| | |
| | | } |
| | | } |
| | | |
| | | // logger.info("[收到移动位置订阅通知]:{}/{}->{}.{}, 时间: {}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(), |
| | | // mobilePosition.getLongitude(), mobilePosition.getLatitude(), System.currentTimeMillis() - startTime); |
| | | logger.debug("[收到移动位置订阅通知]:{}/{}->{}.{}, 时间: {}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(), |
| | | mobilePosition.getLongitude(), mobilePosition.getLatitude(), System.currentTimeMillis() - startTime); |
| | | mobilePosition.setReportSource("Mobile Position"); |
| | | |
| | | mobilePositionService.add(mobilePosition); |
| | |
| | | } |
| | | taskQueue.clear(); |
| | | } |
| | | @Scheduled(fixedRate = 10000) |
| | | public void execute(){ |
| | | logger.info("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size()); |
| | | } |
| | | // @Scheduled(fixedRate = 10000) |
| | | // public void execute(){ |
| | | // logger.debug("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size()); |
| | | // } |
| | | } |