mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-16 02:15:51 +00:00
chore[consumer]: optimize code hierarchy
This commit is contained in:
1 parent
4d22dec398
commit
80143c6653
1 file changed
+5
-5
@@ -464,15 +464,15 @@ public class ZookeeperRegistry implements IRegistry {
|
|||||||
// consumerClientList大于等于1,说明消费者连接成功了
|
// consumerClientList大于等于1,说明消费者连接成功了
|
||||||
if (consumerClientList.size() == 1) {
|
if (consumerClientList.size() == 1) {
|
||||||
var consumer = consumerClientList.get(0);
|
var consumer = consumerClientList.get(0);
|
||||||
if (SessionUtils.isActive(consumer)) {
|
if (!SessionUtils.isActive(consumer)) {
|
||||||
continue;
|
|
||||||
} else {
|
|
||||||
recheckFlag = true;
|
recheckFlag = true;
|
||||||
NetContext.getSessionManager().removeClientSession(consumer);
|
NetContext.getSessionManager().removeClientSession(consumer);
|
||||||
logger.error("[consumer:{}] lost connection, removed from ClientSession", 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);
|
logger.error("[consumerClientList:{}] are multiple duplicate [RegisterVO:{}]", consumerClientList, providerCache);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in new issue
Block a user