MessageClient.cs

MessageClient.cs

    public class MessageClient
    {
        public MessageClient()
        {

        }

        public virtual async Task SendAsync(string message)
        {
            var cq = await GetQueueClient();
            await cq.AddMessageAsync(new CloudQueueMessage(message));
        }

        private static async Task<CloudQueue> GetQueueClient( )
        {
            var keys = await new StorageAccountHelper().GetStorageKeysAsync();
            var storageCredentials = 
                new StorageCredentials(Constants.StorageAccountName, keys.Keys.First().Value);

            var csa = new CloudStorageAccount(storageCredentials, true);
            var cqc = csa.CreateCloudQueueClient();
            var cq = cqc.GetQueueReference(Constants.QueueName);

            await cq.CreateIfNotExistsAsync();
            return cq;
        }
    }