protected Client()

in rocketmq-client-csharp/Client.cs [38:73]

• 25 lines of code
• 1 McCabe index (conditional complexity)

        protected Client(AccessPoint accessPoint, string resourceNamespace)
        {
            _accessPoint = accessPoint;

            // Support IPv4 for now
            AccessPointScheme = rmq::AddressScheme.Ipv4;
            var serviceEndpoint = new rmq::Address();
            serviceEndpoint.Host = accessPoint.Host;
            serviceEndpoint.Port = accessPoint.Port;
            AccessPointEndpoints = new List<rmq::Address> { serviceEndpoint };

            _resourceNamespace = resourceNamespace;

            _clientSettings = new rmq::Settings();

            _clientSettings.AccessPoint = new rmq::Endpoints();
            _clientSettings.AccessPoint.Scheme = rmq::AddressScheme.Ipv4;
            _clientSettings.AccessPoint.Addresses.Add(serviceEndpoint);

            _clientSettings.RequestTimeout = Google.Protobuf.WellKnownTypes.Duration.FromTimeSpan(TimeSpan.FromSeconds(3));

            _clientSettings.UserAgent = new rmq.UA();
            _clientSettings.UserAgent.Language = rmq::Language.DotNet;
            _clientSettings.UserAgent.Version = "5.0.0";
            _clientSettings.UserAgent.Platform = Environment.OSVersion.ToString();
            _clientSettings.UserAgent.Hostname = System.Net.Dns.GetHostName();

            Manager = ClientManagerFactory.getClientManager(resourceNamespace);

            _topicRouteTable = new ConcurrentDictionary<string, TopicRouteData>();
            _updateTopicRouteCts = new CancellationTokenSource();

            _healthCheckCts = new CancellationTokenSource();

            telemetryCts_ = new CancellationTokenSource();
        }