CoreWCF Azure Queue Storage library for .NET

CoreWCF Azure Queue Storage is the service side library that will help existing WCF services to be able to use Azure Queue Storage to communicate with clients as a modern replacement to using MSMQ.

Getting started

Install the package

Install the Microsoft.CoreWCF.Azure.StorageQueues library for .NET withNuGet:

dotnet add package Microsoft.CoreWCF.Azure.StorageQueues --prerelease

Prerequisites

You need anAzure subscription and aStorage Account to use this package.

To create a new Storage Account, you can use theAzure portal,Azure PowerShell, or theAzure CLI.Here's an example using the Azure CLI:

az storage account create --name MyStorageAccount --resource-group MyResourceGroup --location westus --sku Standard_LRS

Configure ASP.NET Core to use CoreWCF with Queue transports

In order to receive requests from the Azure Queue Storage service, you'll need to configure CoreWCF to use queue transports.

public void ConfigureServices(IServiceCollection services){    services.AddServiceModelServices()            .AddQueueTransport();}

Authenticate the service to Azure Queue Storage

To receive requests from the Azure Queue Storage service, you'll need to configure CoreWCF with the appropriate endpoint, and configure credentials. TheAzure Identity library makes it easy to add Microsoft Entra ID support for authenticating with Azure services.

There are multiple authentication mechanisms for Azure Queue Storage. Which mechanism to use is configured via the propertyAzureQueueStorageBinding.Security.Transport.ClientCredentialType. The default authentication mechanism isDefault, which usesDefaultAzureCredential.

public void Configure(IApplicationBuilder app){    app.UseServiceModel(serviceBuilder =>    {        // Configure CoreWCF to dispatch to service type Service        serviceBuilder.AddService<Service>();        // Create a binding instance to use Azure Queue Storage, passing an optional queue name for the dead letter queue        // The default client credential type is Default, which uses DefaultAzureCredential        var aqsBinding = new AzureQueueStorageBinding("DEADLETTERQUEUENAME");        // Add a service endpoint using the AzureQueueStorageBinding        string queueEndpointString = "https://MYSTORAGEACCOUNT.queue.core.windows.net/QUEUENAME";        serviceBuilder.AddServiceEndpoint<Service, IService>(aqsBinding, queueEndpointString);    });}

Learn more about enabling Microsoft Entra ID for authentication with Azure Storage inour documentation.

Other authentication credential mechanisms

If you are using a different credential mechanism such asStorageSharedKeyCredential, you configure the appropriateClientCredentialType on the binding and set the credential on anAzureServiceCredentials instance via an extension method.

public void Configure(IApplicationBuilder app){    app.UseServiceModel(serviceBuilder =>    {        // Configure CoreWCF to dispatch to service type Service        serviceBuilder.AddService<Service>();        // Create a binding instance to use Azure Queue Storage, passing an optional queue name for the dead letter queue        var aqsBinding = new AzureQueueStorageBinding("DEADLETTERQUEUENAME");        // Configure the client credential type to use StorageSharedKeyCredential        aqsBinding.Security.Transport.ClientCredentialType = AzureClientCredentialType.StorageSharedKey;        // Add a service endpoint using the AzureQueueStorageBinding        string queueEndpointString = "https://MYSTORAGEACCOUNT.queue.core.windows.net/QUEUENAME";        serviceBuilder.AddServiceEndpoint<Service, IService>(aqsBinding, queueEndpointString);        // Use extension method to configure CoreWCF to use AzureServiceCredentials and set the        // StorageSharedKeyCredential instance.        serviceBuilder.UseAzureCredentials<Service>(credentials =>        {            credentials.StorageSharedKey = GetStorageSharedKey();        });    });}public StorageSharedKeyCredential GetStorageSharedKey(){    // Fetch shared key using a secure mechanism such as Azure Key Vault    // and construct an instance of StorageSharedKeyCredential to return;    return default;}

Other values for ClientCredentialType areSas,Token, andConnectionString. The credentials classAzureServiceCredentials has corresponding properties to set each of these credential types.

Troubleshooting

If there are any errors receiving a message from Azure Queue Storage, the CoreWCF transport will log the details at theDebug log level. You can configure logging for the categoryMicrosoft.CoreWCF at theDebug level to see any errors.

.ConfigureLogging((logging) =>{    logging.AddFilter("Microsoft.CoreWCF", LogLevel.Debug);});

If a message was recevied from the queue, but wasn't able to be processed, it will be placed in the dead letter queue. You can sepcify the dead letter queue name by passing it to the constructor ofAzureQueueStorageBinding. If not specified, the default value ofdefault-dead-letter-queue will be used.

Key concepts

CoreWCF is an implementation of the service side features of Windows Communication Foundation (WCF) for .NET. The goal of this project is to enable migrating existing WCF services to .NET that are currently using MSMQ and wish to deploy their service to Azure, replacing MSMQ with Azure Queue Storage.

More general samples of using CoreWCF can be found in theCoreWCF samples repository. To create a client to send messages to an Azure Storage Queue, see theMicrosoft.WCF.Azure.StorageQueues documentation.

Contributing

See theStorage CONTRIBUTING.md for details on building,testing, and contributing to this library.

This project welcomes contributions and suggestions. Most contributions require you to agree to a Contributor License Agreement (CLA) declaring that you have the right to, and actually do, grant us the rights to use your contribution. For details, visitcla.microsoft.com.

This project has adopted theMicrosoft Open Source Code of Conduct.For more information see theCode of Conduct FAQ or contactopencode@microsoft.com with any additional questions or comments.