public ConfigFileCredentialsProvider()

in rocketmq-client-csharp/ConfigFileCredentialsProvider.cs [33:56]


        public ConfigFileCredentialsProvider()
        {
            var home = Environment.GetFolderPath(Environment.SpecialFolder.UserProfile);
            string configFileRelativePath = "/.rocketmq/config";
            if (!File.Exists(home + configFileRelativePath))
            {
                return;
            }

            try
            {
                using (var reader = new StreamReader(home + configFileRelativePath))
                {
                    string json = reader.ReadToEnd();
                    var kv = JsonSerializer.Deserialize<Dictionary<string, string>>(json);
                    accessKey = kv["AccessKey"];
                    accessSecret = kv["AccessSecret"];
                    valid = true;
                }
            }
            catch (IOException)
            {
            }
        }