public sealed partial class MainPage : Page
{
public MainPage()
{
this.InitializeComponent();
}
protected async override void OnNavigatedTo(NavigationEventArgs e)
{
// Create the connectionstring
String StorageConnectionString = "DefaultEndpointsProtocol=https;AccountName=[yourAccount];AccountKey=[yourKey]";
// Retrieve storage account from connection string.
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(StorageConnectionString);
// Create the queue client
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
// Retrieve a reference to a queue.
CloudQueue queue = queueClient.GetQueueReference("myqueue");
// Peek at the next message
CloudQueueMessage peekedMessage = await queue.PeekMessageAsync();
// Display message.
this.lblResult.Text = peekedMessage.AsString;
//*** Do Process ***//
//
//
//
//*** Do Process ***//
// Get the next message
CloudQueueMessage retrievedMessage = await queue.GetMessageAsync();
//Process the message in less than 30 seconds, and then delete the message
await queue.DeleteMessageAsync(retrievedMessage);
}
}
จาก Code จะเห็นว่ามีช่วงการทำ Process
//*** Do Process ***//
//
//
//
//*** Do Process ***//
โดยเราสามารถแทรกคำสั่งการทำงานต่าง ๆ เช่น ส่งข้อความไปยัง User หรือทำงานอื่น ๆ จากนั้นเราสามารถลบ Queue ด้วยคำสั่ง
//Process the message in less than 30 seconds, and then delete the message
await queue.DeleteMessageAsync(retrievedMessage);