Adding Azure Service Bus Connectivity

Author: RahulMule

DotNetCore-WebAPI-AzureRedisCache/Controllers/ProductsController.cs

@@ -1,6 +1,7 @@
 using DotNetCore_WebAPI_AzureRedisCache.IRepository;
 using DotNetCore_WebAPI_AzureRedisCache.Models;
 using DotNetCore_WebAPI_AzureRedisCache.Repository;
+using DotNetCore_WebAPI_AzureRedisCache.Services;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 
@@ -12,10 +13,12 @@ public class ProductsController : ControllerBase
 	{
 		IProduct _product;
 		ICache _cache;
-		public ProductsController(IProduct product, ICache cache)
+		AzureServiceBusService _azureservicebusservice;
+		public ProductsController(IProduct product, ICache cache, AzureServiceBusService service)
 		{
 			_product = product;
 			_cache = cache;
+			_azureservicebusservice = service;
 		}
 		[HttpGet]
 		public async Task<IActionResult> GetProducts()
@@ -34,9 +37,11 @@ public async Task<IActionResult> GetProducts()
 			return Ok(products) ;
 		}
 		[HttpPost]
-		public Product AddProducts(Product product)
+		public async Task<ActionResult> AddProducts(Product product)
 		{
-			return _product.AddProduct(product);
+			var response =  _product.AddProduct(product);
+			await _azureservicebusservice.SendProductToQueueAsync(product);
+			return Ok(response);
 		}
 
 		[HttpGet("{id}")]

DotNetCore-WebAPI-AzureRedisCache/DotNetCore-WebAPI-AzureRedisCache.csproj

@@ -8,7 +8,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.17.3" />
     <PackageReference Include="Microsoft.AspNetCore.Mvc.Abstractions" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Azure.ServiceBus" Version="5.2.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="6.0.21" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="6.0.21" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />

DotNetCore-WebAPI-AzureRedisCache/Program.cs

@@ -1,6 +1,7 @@
 using DotNetCore_WebAPI_AzureRedisCache.IRepository;
 using DotNetCore_WebAPI_AzureRedisCache.ProductContext;
 using DotNetCore_WebAPI_AzureRedisCache.Repository;
+using DotNetCore_WebAPI_AzureRedisCache.Services;
 using Microsoft.EntityFrameworkCore;
 using StackExchange.Redis;
 
@@ -17,6 +18,8 @@
 options.UseInMemoryDatabase("Products"));
 builder.Services.AddScoped<IProduct,ProductRepository>();
 builder.Services.AddScoped<ICache, AzureRedisCache>();
+string connstring = builder.Configuration.GetConnectionString("asb");
+builder.Services.AddSingleton(new AzureServiceBusService(connstring, "products"));
 
 builder.Services.AddSwaggerGen();
 

DotNetCore-WebAPI-AzureRedisCache/Services/AzureServiceBusService.cs

@@ -0,0 +1,26 @@
+using Microsoft.Azure.ServiceBus;
+using Newtonsoft.Json;
+using System.Text;
+using System.Text.Json.Serialization;
+
+namespace DotNetCore_WebAPI_AzureRedisCache.Services
+{
+	public class AzureServiceBusService
+	{
+        private readonly string _connectionstring;
+        private readonly string _queuename;
+        public AzureServiceBusService(string connstring, string queuename)
+        {
+            _connectionstring = connstring;
+            _queuename = queuename;                
+        }
+        public async Task SendProductToQueueAsync<T>(T messageobject)
+        {
+            IQueueClient queueClient = new QueueClient(_connectionstring, _queuename);
+            string jsonmessage = JsonConvert.SerializeObject(messageobject);
+            var message = new Message(Encoding.UTF8.GetBytes(jsonmessage));
+            await queueClient.SendAsync(message);
+            await queueClient.CloseAsync();
+        }
+    }
+}

DotNetCore-WebAPI-AzureRedisCache/appsettings.json

@@ -7,6 +7,7 @@
   },
   "AllowedHosts": "*",
   "ConnectionStrings": {
-    "connstring": "sdasda.redis.cache.windows.net:6380,password=QKieBdeqRuZaXc83MlbYFGLCz88YDYg9pAzCaEgKYXQ=,ssl=True,abortConnect=False"
+    "connstring": "sdasda.redis.cache.windows.net:6380,password=QKieBdeqRuZaXc83MlbYFGLCz88YDYg9pAzCaEgKYXQ=,ssl=True,abortConnect=False",
+    "asb": "Endpoint=sb://duausdudasda.servicebus.windows.net/;SharedAccessKeyName=sda;SharedAccessKey=xx7xQGWv72lqePuj2mFK8yEC0u6P/P2or+ASbAvwKw8=;"
   }
 }