PutTask.cs

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