GetTask.cs

using System;
using System.Threading.Tasks;
 
namespace TAG.Simulator.MQ.Tasks
{
    internal class GetTask : MqTask
    {
        private readonly TaskCompletionSource<string> result;
        private readonly string queue;
        private readonly int timeoutMilliseconds;
 
        public GetTask(MqClient Client, string Queue, int TimeoutMilliseconds)
            : base(Client)
        {
            this.queue = Queue;
            this.timeoutMilliseconds = TimeoutMilliseconds;
            this.result = new TaskCompletionSource<string>();
        }
 
        public Task<string> Completed => this.result.Task;
 
        public override bool DoWork()
        {
            try
            {
                string Message = this.Client.GetOne(this.queue, this.timeoutMilliseconds);
                this.result.TrySetResult(Message);
            }
            catch (Exception ex)
            {
                this.result.TrySetException(ex);
            }
 
            return false;
        }
    }
}