Remove retry policy from DefaultServiceBusPersisterConnection parameter

Author: christian147

src/BuildingBlocks/EventBus/EventBusServiceBus/DefaultServiceBusPersisterConnection.cs

@@ -13,8 +13,8 @@ public class DefaultServiceBusPersisterConnection :IServiceBusPersisterConnectio
 
         bool _disposed;
 
-        public DefaultServiceBusPersisterConnection(ServiceBusConnectionStringBuilder serviceBusConnectionStringBuilder, 
-            TimeSpan operationTimeout, RetryPolicy retryPolicy, ILogger<DefaultServiceBusPersisterConnection> logger)
+        public DefaultServiceBusPersisterConnection(ServiceBusConnectionStringBuilder serviceBusConnectionStringBuilder,
+            ILogger<DefaultServiceBusPersisterConnection> logger)
         {
             _logger = logger ?? throw new ArgumentNullException(nameof(logger));
 

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

@@ -81,7 +81,7 @@ public void ConfigureServices(IServiceCollection services)
 
                     var serviceBusConnection = new ServiceBusConnectionStringBuilder(settings.ServiceBusConnection);
 
-                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, TimeSpan.FromSeconds(5) , RetryPolicy.Default,logger);
+                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, logger);
                 });
             }
             else
@@ -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 = Configuration.GetValue<string>("SubscriptionClientName");
+                    var subscriptionClientName = Configuration["SubscriptionClientName"];
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger, 
                         eventBusSubcriptionsManager, subscriptionClientName);

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

@@ -120,7 +120,7 @@ public void ConfigureServices(IServiceCollection services)
 
                     var serviceBusConnection = new ServiceBusConnectionStringBuilder(settings.ServiceBusConnection);
 
-                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, TimeSpan.FromSeconds(5), RetryPolicy.Default, logger);
+                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, logger);
                 });
             }
             else
@@ -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 = Configuration.GetValue<string>("SubscriptionClientName");
+                    var subscriptionClientName = Configuration["SubscriptionClientName"];
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger,
                         eventBusSubcriptionsManager, subscriptionClientName);

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

@@ -123,7 +123,7 @@ public IServiceProvider ConfigureServices(IServiceCollection services)
 
                     var serviceBusConnection = new ServiceBusConnectionStringBuilder(Configuration["ServiceBusConnection"]);
 
-                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, TimeSpan.FromSeconds(5), RetryPolicy.Default, logger);
+                    return new DefaultServiceBusPersisterConnection(serviceBusConnection, logger);
                 });
             }
             else
@@ -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 = Configuration.GetValue<string>("SubscriptionClientName");
+                    var subscriptionClientName = Configuration["SubscriptionClientName"];
 
                     return new EventBusServiceBus(serviceBusPersisterConnection, logger,
                         eventBusSubcriptionsManager, subscriptionClientName);