| | |
| | | } |
| | | } |
| | | |
| | | @Scheduled(fixedRate = 10000) //每1秒执行一次 |
| | | public void execute(){ |
| | | logger.info("[待处理Notify-目录订阅消息数量]: {}", taskQueue.size()); |
| | | } |
| | | // @Scheduled(fixedRate = 10000) //每1秒执行一次 |
| | | // public void execute(){ |
| | | // logger.info("[待处理Notify-目录订阅消息数量]: {}", taskQueue.size()); |
| | | // } |
| | | } |
| | |
| | | } |
| | | taskQueue.clear(); |
| | | } |
| | | @Scheduled(fixedRate = 10000) |
| | | public void execute(){ |
| | | logger.info("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size()); |
| | | } |
| | | // @Scheduled(fixedRate = 10000) |
| | | // public void execute(){ |
| | | // logger.debug("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size()); |
| | | // } |
| | | } |