third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: worker heartbeat use wrong thread pool

Browse Source
This commit is contained in:
tjq 2022-09-12 21:26:01 +08:00
parent e6d32c9a05
commit fd562d8ea0
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoService.java
View File

@ -10,6 +10,10 @@ import tech.powerjob.server.common.module.ServerInfo;
*/ */
public interface ServerInfoService { public interface ServerInfoService {
/**
* fetch current server info
* @return ServerInfo
*/
ServerInfo fetchServiceInfo(); ServerInfo fetchServiceInfo();
} }

1
powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java
View File

@ -88,7 +88,6 @@ public class ServerInfoServiceImpl implements ServerInfoService {
log.info("[ServerInfoService] ip:{}, id:{}, cost:{}", ip, serverInfo.getId(), sw); log.info("[ServerInfoService] ip:{}, id:{}, cost:{}", ip, serverInfo.getId(), sw);
} }
@Async(PJThreadPool.TIMING_POOL)
@Scheduled(fixedRate = 15000, initialDelay = 15000) @Scheduled(fixedRate = 15000, initialDelay = 15000)
public void heartbeat() { public void heartbeat() {
serverInfoRepository.updateGmtModifiedByIp(serverInfo.getIp(), new Date()); serverInfoRepository.updateGmtModifiedByIp(serverInfo.getIp(), new Date());