Add SubscriptionClientName EnvironmentVariable

Author: christian147

src/Services/Basket/Basket.API/Startup.cs

@@ -138,7 +138,7 @@ private void RegisterServiceBus(IServiceCollection services)
                     var serviceBusPersisterConnection = sp.GetRequiredService<IServiceBusPersisterConnection>();
                     var logger = sp.GetRequiredService<ILogger<EventBusServiceBus>>();
                     var eventBusSubcriptionsManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
-                    var subscriptionClientName = "Basket";
+                    var subscriptionClientName = Configuration.GetValue<string>("SubscriptionClientName");
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger, 
                         eventBusSubcriptionsManager, subscriptionClientName);

src/Services/Basket/Basket.API/appsettings.json

@@ -10,5 +10,6 @@
   "IdentityUrl": "http://localhost:5105",
   "ConnectionString": "127.0.0.1",
   "ServiceBusConnection": "Endpoint=sb://eshoponazuretest.servicebus.windows.net/;SharedAccessKeyName=Root;SharedAccessKey=Xo9wlr4bRv5iqTTditgFhTeZqxIpczaAUqfspo+QE/s=;EntityPath=eshop_event_bus",
-  "AzureServiceBus": "true"
-}
+  "AzureServiceBus": "true",
+  "SubscriptionClientName": "Basket"
+}

src/Services/Catalog/Catalog.API/Startup.cs

@@ -205,7 +205,7 @@ private void RegisterServiceBus(IServiceCollection services)
                     var serviceBusPersisterConnection = sp.GetRequiredService<IServiceBusPersisterConnection>();
                     var logger = sp.GetRequiredService<ILogger<EventBusServiceBus>>();
                     var eventBusSubcriptionsManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
-                    var subscriptionClientName = "Catalog";
+                    var subscriptionClientName = Configuration.GetValue<string>("SubscriptionClientName");
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger,
                         eventBusSubcriptionsManager, subscriptionClientName);

src/Services/Catalog/Catalog.API/settings.json

@@ -10,5 +10,6 @@
     }
   },
   "ServiceBusConnection": "Endpoint=sb://eshoponazuretest.servicebus.windows.net/;SharedAccessKeyName=Root;SharedAccessKey=Xo9wlr4bRv5iqTTditgFhTeZqxIpczaAUqfspo+QE/s=;EntityPath=eshop_event_bus",
-  "AzureServiceBus": "true"
+  "AzureServiceBus": "true",
+  "SubscriptionClientName": "Catalog"
 }

src/Services/Ordering/Ordering.API/Startup.cs

@@ -199,7 +199,7 @@ private void RegisterServiceBus(IServiceCollection services)
                     var serviceBusPersisterConnection = sp.GetRequiredService<IServiceBusPersisterConnection>();
                     var logger = sp.GetRequiredService<ILogger<EventBusServiceBus>>();
                     var eventBusSubcriptionsManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
-                    var subscriptionClientName = "Ordering";
+                    var subscriptionClientName = Configuration.GetValue<string>("SubscriptionClientName");
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger,
                         eventBusSubcriptionsManager, subscriptionClientName);

src/Services/Ordering/Ordering.API/settings.json

@@ -10,5 +10,6 @@
     }
   },
   "ServiceBusConnection": "Endpoint=sb://eshoponazuretest.servicebus.windows.net/;SharedAccessKeyName=Root;SharedAccessKey=Xo9wlr4bRv5iqTTditgFhTeZqxIpczaAUqfspo+QE/s=;EntityPath=eshop_event_bus",
-  "AzureServiceBus": "true"
+  "AzureServiceBus": "true",
+  "SubscriptionClientName": "Ordering"
 }