public override void Initialize()
{
    base.Initialize();
 
    // [Initialization of _daServerMgtWrappers and other non-QuickOPC specific setup]
 
    foreach (var group in /* [Group setup] */)
    {
        // [Setup of readTags, writeTags, etc.]
 
        var daServerMgtWrapper = new QuickOPC_DaServerMgtWrapper()
        {
            MachineName = group.FirstOrDefault().MachineName,
            OpcServerName = group.FirstOrDefault().OpcServerName,
            Url = url,
            ReadTags = readTags,
            ReadTags_Identifiers = readTagIdentifiers,
            WriteTags = writeTags,
            _revisedUpdateRate = int.Parse(this._driverSettings["Subscription Update Rate"].Value),
            _percentDeadband = float.Parse(this._driverSettings["Subscription Deadband"].Value)
        };
 
        Task.Run(
            () =>
            {
                if (daServerMgtWrapper.TryBrowse() && daServerMgtWrapper.TrySubscribe())
                {
                    daServerMgtWrapper._daServerMgt.ItemChanged += OnDataChanged;
                    // [LicenseCheck call]
                }
                else
                {
                    // [Error handling for connection failure]
                }
            }
        );
        this._daServerMgtWrappers.Add(daServerMgtWrapper);
    }
 
    // [Error logging]
}
 
public QuickOPC_DaServerMgtWrapper()
{
    //Addresses DCOM hardening changes by Microsoft CVE-2021-26414
    ComManagement.Instance.Configuration.SecurityParameters.EnsureDataIntegrity = true;
    ComManagement.Instance.AssureSecurityInitialization();
 
    _daServerMgt = new EasyDAClient();
    //Increase timeout for connections
    _daServerMgt.InstanceParameters.Timeouts.WriteItem = 6000;
    _daServerMgt.InstanceParameters.Timeouts.ReadItem = 6000;
    _daServerMgt.InstanceParameters.HoldPeriods.TopicRead = 200;
    _daServerMgt.InstanceParameters.HoldPeriods.TopicWrite = 200;
 
    //This line was recommended to force usage of their underlying rewrite for the DA Client
    _daServerMgt.InstanceParameters.EnableNativeClient = false;
 
    _daServerMgt.ItemChanged += ServerStateChanged;
}
 
public bool TryBrowse()
{
    ServerElementCollection serverElements;
    ProblematicTagsCount = new List<string>();
 
    try
    {
        serverElements = _daServerMgt.BrowseServers(MachineName);
        //check if OPC Server Exists in the specified machine and return false if not
        for (int i = 0; i < serverElements.Count; i++)
        {
            if (serverElements[i].ProgId.Contains(OpcServerName))
            {
                // [Setup for tag verification]
 
                DAVtqResult[] vtqResults = _daServerMgt.ReadMultipleItems(OpcServerName, tagNames);
 
                // [Checking for problematic tags and logging]
 
                HasConnection = true;
                return true;
            }
        }
 
        Logger.Log(LoggingLevel.Error, $"Specified OPC Server: {OpcServerName} does not exist on the Machine: {MachineName}");
        HasConnection = false;
        return false;
    }
    catch (OpcException opcException)
    {
        HasConnection = false;
        Logger.Log(LoggingLevel.Error, opcException.GetBaseException().Message + $": {MachineName}");
        return false;
    }
}
 
public DAVtqResult[] Read()
{
    DAVtqResult[] vtqReadResults = _daServerMgt.ReadMultipleItems(OpcServerName, ReadTags_Identifiers);
    List<string> errorMessages = new List<string>();
 
    for (int i = 0; i < vtqReadResults.Length; i++)
    {
        if (!vtqReadResults[i].Succeeded)
        {
            string errorMessage = $"Tag '{ReadTags_Identifiers[i]}': {vtqReadResults[i].ErrorMessageBrief}";
            errorMessages.Add(errorMessage);
            Console.WriteLine($"{OpcServerName}: vtqResults[{i}] *** Failure: {vtqReadResults[i].ErrorMessageBrief}");
        }
    }
    return vtqReadResults;
}