fea: 修复检查选举服务

go-home-admin · Sep 6, 2023 · d906d9c · d906d9c
1 parent 1fa2bc1
commit d906d9c
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/bootstrap/servers/election.go b/bootstrap/servers/election.go
@@ -69,13 +69,13 @@ func (k *Election) Run() {
 func (k *Election) Exit() {
 	if k.isRunNode {
 		k.Connect.Client.Del(context.Background(), k.key)
-	}
 
-	if app.HasBean("queue") && k.isRunNode {
-		// 广播到其他副本
-		NewQueue().Publish(message.ElectionClose{
-			Time: time.Now().Unix(),
-		})
+		if app.HasBean("queue") {
+			// 广播到其他副本
+			NewQueue().Publish(message.ElectionClose{
+				Time: time.Now().Unix(),
+			})
+		}
 	}
 }