ConnectionTask.cs

using System;
using System.Threading.Tasks;
 
namespace TAG.Simulator.MQ.Tasks
{
    internal class ConnectionTask : MqTask
    {
        private readonly TaskCompletionSource<bool> result;
        private readonly string userName;
        private readonly string password;
 
        public ConnectionTask(MqClient Client, string UserName, string Password)
            : base(Client)
        {
            this.userName = UserName;
            this.password = Password;
            this.result = new TaskCompletionSource<bool>();
        }
 
        public Task Completed => this.result.Task;
 
        public override bool DoWork()
        {
            try
            {
                this.Client.Connect(this.userName, this.password);
                this.result.TrySetResult(true);
            }
            catch (Exception ex)
            {
                this.result.TrySetException(ex);
            }
 
            return false;
        }
    }
}