diff --git a/src/Services/Basket/Basket.API/Startup.cs b/src/Services/Basket/Basket.API/Startup.cs index 7a12607c8..9c975d4ff 100644 --- a/src/Services/Basket/Basket.API/Startup.cs +++ b/src/Services/Basket/Basket.API/Startup.cs @@ -126,10 +126,10 @@ namespace Microsoft.eShopOnContainers.Services.Basket.API }); services.AddTransient(); - RegisterServiceBus(services); + RegisterEventBus(services); } - private void RegisterServiceBus(IServiceCollection services) + private void RegisterEventBus(IServiceCollection services) { if (Configuration.GetValue("AzureServiceBusEnabled")) { diff --git a/src/Services/Catalog/Catalog.API/Startup.cs b/src/Services/Catalog/Catalog.API/Startup.cs index 1b90bd270..25255cbaa 100644 --- a/src/Services/Catalog/Catalog.API/Startup.cs +++ b/src/Services/Catalog/Catalog.API/Startup.cs @@ -138,7 +138,7 @@ }); } - RegisterServiceBus(services); + RegisterEventBus(services); } public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory) @@ -170,6 +170,8 @@ .Options); integrationEventLogContext.Database.Migrate(); + + ConfigureEventBus(app); } private void WaitForSqlAvailability(CatalogContext ctx, ILoggerFactory loggerFactory, int? retry = 0) @@ -196,7 +198,7 @@ } } - private void RegisterServiceBus(IServiceCollection services) + private void RegisterEventBus(IServiceCollection services) { if (Configuration.GetValue("AzureServiceBusEnabled")) { @@ -218,5 +220,9 @@ services.AddSingleton(); } + protected virtual void ConfigureEventBus(IApplicationBuilder app) + { + var eventBus = app.ApplicationServices.GetRequiredService(); + } } } diff --git a/src/Services/Ordering/Ordering.API/Startup.cs b/src/Services/Ordering/Ordering.API/Startup.cs index a3cceb9a5..7728725c1 100644 --- a/src/Services/Ordering/Ordering.API/Startup.cs +++ b/src/Services/Ordering/Ordering.API/Startup.cs @@ -142,7 +142,7 @@ }); } - RegisterServiceBus(services); + RegisterEventBus(services); services.AddOptions(); @@ -178,6 +178,8 @@ .UseSqlServer(Configuration["ConnectionString"], b => b.MigrationsAssembly("Ordering.API")) .Options); integrationEventLogContext.Database.Migrate(); + + ConfigureEventBus(app); } protected virtual void ConfigureAuth(IApplicationBuilder app) @@ -191,7 +193,7 @@ }); } - private void RegisterServiceBus(IServiceCollection services) + private void RegisterEventBus(IServiceCollection services) { if (Configuration.GetValue("AzureServiceBusEnabled")) { @@ -213,5 +215,10 @@ services.AddSingleton(); } + + protected virtual void ConfigureEventBus(IApplicationBuilder app) + { + var eventBus = app.ApplicationServices.GetRequiredService(); + } } }