Getting data from Azure Service Bus Queues in ASP.NET Core Console

 

• Go to Solution and right click on it select Add and select New Project.
• Select Console App (.Net Core) and click on Next.
  
• Give a name to the service and click on Create.
  
• Create a new file called appsettings.json & add the Azure service connection string as below.

  {
    "AppSettings": {
      "QueueConnectionString": "<replace your RootManageSharedAccessKey here>",
      "QueueName": "order-queue"
    }
  }

  JSON
• First, we have to install the Azure Service Bus NuGet package.
  
• So this service needs to listen to messages from Azure Service bus we can create this as a Windows service. Along with that add the below code to read to the Appsettings from appsettings.json. So create a class called AppSettings.cs as mentioned below.

  public class AppSettings
  {
      public string QueueConnectionString { get; set; }
      public string QueueName { get; set; }
  }

  C#
• To configure our service first we need to install the below packages.
  
  
  
• After that add the below code in `program. cs` to configure our service.

  class Program
  {
      static void Main(string[] args)
      {
          IServiceCollection serviceDescriptors = new ServiceCollection();
          Host.CreateDefaultBuilder(args)
              .UseWindowsService()
              .ConfigureHostConfiguration(configHost =>
              {
                  configHost.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true).Build();
              })
              .ConfigureServices((hostContext, services) =>
              {
                  var appSettingsConfig = hostContext.Configuration.GetSection(nameof(AppSettings));
  
                  services.AddOptions();
                  services.Configure<AppSettings>(appSettingsConfig);
                  services.AddSingleton(appSettingsConfig);
              }).Build().Run();
      }
  }

  C#
• Now the next part is to create Background service to listen to messages. So create a class called CraeteOrderHandler.cs and inherit it with class `BackgroundService`. Now override the `ExecuteAsync` and `StopAsync` method of BackgroundService class.

  using System;
  using System.Text;
  using System.Threading;
  using System.Threading.Tasks;
  using Microsoft.Azure.ServiceBus;
  using Microsoft.Extensions.Hosting;
  using Microsoft.Extensions.Options;
  
  namespace OrderService
  {
      public class CraeteOrderHandler : BackgroundService
      {
          private readonly AppSettings _appSettings;
          private IQueueClient _orderQueueClient;
  
          public CraeteOrderHandler(IOptions<AppSettings> appSettings)
          {
              _appSettings = appSettings?.Value ?? throw new ArgumentNullException(nameof(appSettings));
          }
  
          public async Task Handle(Message message, CancellationToken cancelToken)
          {
              if (message == null)
                  throw new ArgumentNullException(nameof(message));
  
              var body = Encoding.UTF8.GetString(message.Body);
              Console.WriteLine($"Create Order Details are: {body}");
              await _orderQueueClient.CompleteAsync(message.SystemProperties.LockToken).ConfigureAwait(false);
          }
  
          public virtual Task HandleFailureMessage(ExceptionReceivedEventArgs exceptionReceivedEventArgs)
          {
              if (exceptionReceivedEventArgs == null)
                  throw new ArgumentNullException(nameof(exceptionReceivedEventArgs));
              return Task.CompletedTask;
          }
  
          protected override Task ExecuteAsync(CancellationToken stoppingToken)
          {
              var messageHandlerOptions = new MessageHandlerOptions(HandleFailureMessage)
              {
                  MaxConcurrentCalls = 5,
                  AutoComplete = false,
                  MaxAutoRenewDuration = TimeSpan.FromMinutes(10)
              };
              _orderQueueClient = new QueueClient(_appSettings.QueueConnectionString, _appSettings.QueueName);
              _orderQueueClient.RegisterMessageHandler(Handle, messageHandlerOptions);
              Console.WriteLine($"{nameof(CraeteOrderHandler)} service has started.");
              return Task.CompletedTask;
          }
  
          public override async Task StopAsync(CancellationToken stoppingToken)
          {
              Console.WriteLine($"{nameof(CraeteOrderHandler)} service has stopped.");
              await _orderQueueClient.CloseAsync().ConfigureAwait(false);
          }
      }
  }

  C#
• ExecuteAsync() method calls when service starts so we have setup a queue client object and also registered Handle method to listen to messages.
• In StopAsync() method we close the queue client connection.
• In Handle() method we just extract body from messasge which contains our actual data and just print it in console.
• After that let's register our hosted service by adding below line into `ConfigureServices` method in Program.cs class.

  services.AddHostedService<CraeteOrderHandler>();

  C#
• So let's build and run the service to listen to messages. Start order web api and send message to queue which our OrderService going to listen to.
  
  

Conc