using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Windows.Azure.Storage;
using System.Xml.Linq;

namespace SimpleQueueConsoleApp
{
    class Program
    {
        static void Main(string[] args)
        {
            ConnectionDetails connectionDetails = new ConnectionDetails(BlobConnectionModes.Cloud);

            if (connectionDetails.ConnectionMode == BlobConnectionModes.Local)
            {
                connectionDetails.Account = "devstoreaccount1";
                connectionDetails.Endpoint = "http://127.0.0.1:10001/{0}/";
                connectionDetails.Key = "Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==";
            }
            else
            {
                connectionDetails.Account = "davidlem";
                connectionDetails.Endpoint = "http://{0}.queue.core.windows.net/";
                connectionDetails.Key = "6QHNz3DZHBCLAybUZEr7Ok6ke4aaS+NVmqstecrKKRR2Ohnwd57qBJ4BYNq6CPT73APRjmAMcnqTAQM4VNuCgw==";
            }

            Queue queue = new Queue(connectionDetails, "testqueue"); // don't use capital letters!
            QueueResponse response;

            response =  queue.Create();

            Console.WriteLine(response.ResponseCode.ToString());
            Console.WriteLine(response.ResponseMessage.ToString());
            Console.WriteLine(response.ResponseBody);

            for (int i = 0; i < 100; i++)
            {
                response = queue.PutMessage("The time is " + DateTime.UtcNow.Ticks.ToString());

                Console.WriteLine("--> Message Start");
                Console.WriteLine(response.ResponseCode.ToString());
                Console.WriteLine(response.ResponseMessage.ToString());
                Console.WriteLine(response.ResponseBody);
                Console.WriteLine("--> Message End");
                Console.WriteLine("");


            }

            response = queue.GetMessage(5);
            Console.WriteLine(response.ResponseCode.ToString());
            Console.WriteLine(response.ResponseMessage.ToString());
            Console.WriteLine(response.ResponseBody);

            foreach (QueueMessage message in response.GetQueueMessages())
            {
                Console.WriteLine("New Message -->");
                Console.WriteLine("msgid = " + message.MessageId);
                Console.WriteLine("InsertionTime = " + message.InsertionTime.ToString());
                Console.WriteLine("ExpirationTime = " + message.ExpirationTime.ToString());
                Console.WriteLine("PopReceipt = " + message.PopReceipt);
                Console.WriteLine("TimeNextVisible = " + message.TimeNextVisible.ToString());
                Console.WriteLine("");
            }

            Console.WriteLine("Delete Queue?");
            Console.ReadKey();
            response = queue.Delete();

            Console.WriteLine(response.ResponseCode.ToString());
            Console.WriteLine(response.ResponseMessage.ToString());
            Console.WriteLine(response.ResponseBody);


            Console.ReadKey();
        }
    }
}