Event-Driven Architecture in the Clouds with Windows Azure

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.WindowsAzure;
using Microsoft.WindowsAzure.StorageClient;
using Microsoft.WindowsAzure.ServiceRuntime;
using Microsoft.WindowsAzure.Diagnostics;
using FlightUpdates.Utility.Constants;
namespace FlightUpdates.Utility
{
    /// <summary>
    ///  Manages CloudStorageAccounts used in the flightupdates soultion
    /// </summary>
    public static class CloudStorageUtil
    {
        /// <summary>
        /// Returns CloudStorageAccount for the flight update queue
        /// </summary>
        /// <returns>CloudStorageAccount->FlightUpdatesQueue </returns>
        public static CloudStorageAccount GetFlightUpdatesQueue()
        {
            CloudStorageAccount.SetConfigurationSettingPublisher((configName, configSetter) =>
            {
                // Provide the configSetter with the initial value
                configSetter(RoleEnvironment.GetConfigurationSettingValue(configName));

                RoleEnvironment.Changed += (sender, arg) =>
                {
                    if (arg.Changes.OfType<RoleEnvironmentConfigurationSettingChange>()
                        .Any((change) => (change.ConfigurationSettingName == configName)))
                    {
                        // The corresponding configuration setting has changed, propagate the value
                        if (!configSetter(RoleEnvironment.GetConfigurationSettingValue(configName)))
                        {
                            // In this case, the change to the storage account credentials in the
                            // service configuration is significant enough that the role needs to be
                            // recycled in order to use the latest settings. (for example, the 
                            // endpoint has changed)
                            RoleEnvironment.RequestRecycle();
                        }
                    }
                };
            });

            return (CloudStorageAccount.FromConfigurationSetting(CloudQueues.FlightDelayMessages));

        }

    }
}