How to add data to a Queues in Microsoft. AZURE and read data from queue in Microsoft.Azure

How to add data to a Queues under Microsoft. AZURE and read data from queue​​ in Microsoft.Azure?

using​​ System;

using​​ System.Collections.Generic;

using​​ System.Linq;

using​​ System.Text;

using​​ System.Threading.Tasks;

using​​ Microsoft.Azure;

using​​ Microsoft.WindowsAzure.Storage;

using​​ Microsoft.WindowsAzure.Storage.Queue;

 

namespace​​ AzureTableTest

{

 ​​ ​​ ​​​​ class​​ Program

 ​​ ​​ ​​​​ {

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ static​​ void​​ Main(string[] args)

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ {

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ string​​ storageconnection = System.Configuration.ConfigurationManager.AppSettings.Get("StorageConnectionString");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudStorageAccount​​ storageAccount =​​ CloudStorageAccount.Parse(storageconnection);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Create a Queue

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueClient​​ queueClient = storageAccount.CreateCloudQueueClient();

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueue​​ myqueue = queueClient.GetQueueReference("queue");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ myqueue.CreateIfNotExists();

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Add a message in a queue

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //CloudQueueMessage newmesssage = new CloudQueueMessage("This is a desperate cry for a help!");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //myqueue.AddMessage(newmesssage);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueMessage​​ newmessage =​​ new​​ CloudQueueMessage("This is the second message!");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ myqueue.AddMessage(newmessage);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Read queue message but will not remove from queue.

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueMessage​​ oldmessageQueu = myqueue.PeekMessage();

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ Console.WriteLine(oldmessageQueu.AsString);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ Console.ReadKey();

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ }

 ​​ ​​ ​​​​ }

}

 

Output:

 

Read data and remove from the Queue:

 

using​​ System;

using​​ System.Collections.Generic;

using​​ System.Linq;

using​​ System.Text;

using​​ System.Threading.Tasks;

using​​ Microsoft.Azure;

using​​ Microsoft.WindowsAzure.Storage;

using​​ Microsoft.WindowsAzure.Storage.Queue;

 

namespace​​ AzureTableTest

{

 ​​ ​​ ​​​​ class​​ Program

 ​​ ​​ ​​​​ {

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ static​​ void​​ Main(string[] args)

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ {

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ string​​ storageconnection = System.Configuration.ConfigurationManager.AppSettings.Get("StorageConnectionString");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudStorageAccount​​ storageAccount =​​ CloudStorageAccount.Parse(storageconnection);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Create a Queue

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueClient​​ queueClient = storageAccount.CreateCloudQueueClient();

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueue​​ myqueue = queueClient.GetQueueReference("queue");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ myqueue.CreateIfNotExists();

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Add a message in a queue

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //CloudQueueMessage newmesssage = new CloudQueueMessage("This is a desperate cry for a help!");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //myqueue.AddMessage(newmesssage);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueMessage​​ newmessage =​​ new​​ CloudQueueMessage("This is the third message!");

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ myqueue.AddMessage(newmessage);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ //Read queue message but will remove from queue.

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ CloudQueueMessage​​ oldmessageQueu = myqueue.GetMessage();

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ Console.WriteLine(oldmessageQueu.AsString);

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ Console.ReadKey();

 

 ​​ ​​ ​​ ​​ ​​ ​​ ​​​​ }

 ​​ ​​ ​​​​ }

}

Output:

1)

2)

3)

 

(Visited 33 times, 1 visits today)

Leave a Reply

Your email address will not be published. Required fields are marked *