From 80143c665377fcfea42bbd35ef492ae985149755 Mon Sep 17 00:00:00 2001 From: godotg Date: Sun, 14 Jan 2024 18:48:52 +0800 Subject: [PATCH] chore[consumer]: optimize code hierarchy --- .../zfoo/net/consumer/registry/ZookeeperRegistry.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java index 6f8e5b7d..1a84b495 100644 --- a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java +++ b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java @@ -464,15 +464,15 @@ public class ZookeeperRegistry implements IRegistry { // consumerClientList大于等于1，说明消费者连接成功了 if (consumerClientList.size() == 1) { var consumer = consumerClientList.get(0); - if (SessionUtils.isActive(consumer)) { - continue; - } else { + if (!SessionUtils.isActive(consumer)) { recheckFlag = true; NetContext.getSessionManager().removeClientSession(consumer); logger.error("[consumer:{}] lost connection, removed from ClientSession", consumer); - continue; } - } else if (consumerClientList.size() > 1) { + continue; + } + + if (consumerClientList.size() > 1) { logger.error("[consumerClientList:{}] are multiple duplicate [RegisterVO:{}]", consumerClientList, providerCache); continue; }