From fd562d8ea00d067a5978502b901562b06b1637f3 Mon Sep 17 00:00:00 2001 From: tjq Date: Mon, 12 Sep 2022 21:26:01 +0800 Subject: [PATCH] fix: worker heartbeat use wrong thread pool --- .../powerjob/server/remote/server/self/ServerInfoService.java | 4 ++++ .../server/remote/server/self/ServerInfoServiceImpl.java | 1 - 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoService.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoService.java index a01b8c0b..5c799a7a 100644 --- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoService.java +++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoService.java @@ -10,6 +10,10 @@ import tech.powerjob.server.common.module.ServerInfo; */ public interface ServerInfoService { + /** + * fetch current server info + * @return ServerInfo + */ ServerInfo fetchServiceInfo(); } diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java index 94bb12ca..eb94b58b 100644 --- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java +++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/self/ServerInfoServiceImpl.java @@ -88,7 +88,6 @@ public class ServerInfoServiceImpl implements ServerInfoService { log.info("[ServerInfoService] ip:{}, id:{}, cost:{}", ip, serverInfo.getId(), sw); } - @Async(PJThreadPool.TIMING_POOL) @Scheduled(fixedRate = 15000, initialDelay = 15000) public void heartbeat() { serverInfoRepository.updateGmtModifiedByIp(serverInfo.getIp(), new Date());