public synchronized void updateHasConnectedToAllMembers(Set<String> allMemberNodeIds) {
        boolean connectedToAllMembers = true;
        for (String nodeId : allMemberNodeIds) {
            if (!isMemberConnected(nodeId)
                    && !discoveryService.getLocalNodeStatusManager()
                            .isLocalNodeId(nodeId)) {
                connectedToAllMembers = false;
                break;
            }
        }
        hasConnectedToAllMembers = connectedToAllMembers;
    }
Use supplier rather than just listener so that we can bind each generated listener to a
specific TcpConnection to make logic simple
turms-server-common/src/main/java/im/turms/server/common/infra/cluster/service/connection/ConnectionService.java