gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

Merge remote-tracking branch 'upstream/dev_3.2.0' into dev_3.2.0

Browse Source
This commit is contained in:
dhb52 2024-03-31 16:10:09 +08:00
commit 31b317a3b1
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
easy-retry-datasource/easy-retry-mysql-datasource/src/main/resources/mysql/mapper/ServerNodeMapper.xml
View File

@ -52,7 +52,6 @@
</foreach> </foreach>
) tt ) tt
SET rt.expire_at = tt.expire_at, rt.context_path = tt.context_path, SET rt.expire_at = tt.expire_at, rt.context_path = tt.context_path,
rt.context_path = tt.context_path
WHERE rt.host_id = tt.host_id and rt.host_ip = tt.host_ip WHERE rt.host_id = tt.host_id and rt.host_ip = tt.host_ip
</update> </update>
<select id="countActivePod" <select id="countActivePod"

2
easy-retry-server/easy-retry-server-common/src/main/java/com/aizuda/easy/retry/server/common/register/ServerRegister.java
View File

@ -122,6 +122,8 @@ public class ServerRegister extends AbstractRegister {
for (final ServerNode node : serverNodes) { for (final ServerNode node : serverNodes) {
// 刷新全量本地缓存 // 刷新全量本地缓存
CacheRegisterTable.addOrUpdate(node); CacheRegisterTable.addOrUpdate(node);
// 刷新过期时间
CacheConsumerGroup.addOrUpdate(node.getGroupName(), node.getNamespaceId());
} }
} }
} catch (Exception e) { } catch (Exception e) {