Browse Source
Implementing IHostedService GracePeriodManagerService with base class BackgroundService from ".NET Core 2.1" in a separate WebHost (Seggregated service for background tasks of the Ordering Business Microservice) named Ordering.BackgroundTasksWebHost
pull/811/head
Cesar De la Torre
7 years ago
16 changed files with 700 additions and 1 deletions
Unified View
Diff Options
-
+12 -0.dockerignore
-
+1 -0docker-compose.dcproj
-
+17 -0docker-compose.override.yml
-
+9 -0docker-compose.yml
-
+103 -1eShopOnContainers-ServicesAndWebApps.sln
-
+8 -0src/Services/Ordering/Ordering.BackgroundTasksHost/Ordering.BackgroundTasksHost.csproj
-
+34 -0src/Services/Ordering/Ordering.BackgroundTasksHost/Program.cs
-
+6 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/Dockerfile
-
+83 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/HostedServices/BackgroundService.cs
-
+94 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/HostedServices/GracePeriodManagerService.cs
-
+18 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/Infrastructure/AutofacModules/ApplicationModule.cs
-
+27 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/Ordering.BackgroundTasksWebHost.csproj
-
+13 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/OrderingBackgroundSettings.cs
-
+37 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/Program.cs
-
+219 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/Startup.cs
-
+19 -0src/Services/Ordering/Ordering.BackgroundTasksWebHost/settings.json
+ 12
- 0
.dockerignore
View File
| @ -0,0 +1,12 @@ | |||||
| .dockerignore | |||||
| .env | |||||
| .git | |||||
| .gitignore | |||||
| .vs | |||||
| .vscode | |||||
| docker-compose.yml | |||||
| docker-compose.*.yml | |||||
| */bin | |||||
| */obj | |||||
| !obj/Docker/publish/* | |||||
| !obj/Docker/empty/ | |||||
+ 1
- 0
docker-compose.dcproj
View File
+ 17
- 0
docker-compose.override.yml
View File
+ 9
- 0
docker-compose.yml
View File
+ 103
- 1
eShopOnContainers-ServicesAndWebApps.sln
View File
+ 8
- 0
src/Services/Ordering/Ordering.BackgroundTasksHost/Ordering.BackgroundTasksHost.csproj
View File
| @ -0,0 +1,8 @@ | |||||
| <Project Sdk="Microsoft.NET.Sdk"> | |||||
| <PropertyGroup> | |||||
| <OutputType>Exe</OutputType> | |||||
| <TargetFramework>netcoreapp2.0</TargetFramework> | |||||
| </PropertyGroup> | |||||
| </Project> | |||||
+ 34
- 0
src/Services/Ordering/Ordering.BackgroundTasksHost/Program.cs
View File
| @ -0,0 +1,34 @@ | |||||
| using System; | |||||
| // NOT READY WITH Microsoft.Extensions.Hosting out of ASP.NET Core until .NET Core 2.1 | |||||
| //using System.Threading.Tasks; | |||||
| //using Microsoft.Extensions.DependencyInjection; | |||||
| //using Microsoft.Extensions.Hosting; | |||||
| namespace Ordering.BackgroundTasksHost | |||||
| { | |||||
| class Program | |||||
| { | |||||
| static void Main(string[] args) | |||||
| { | |||||
| Console.WriteLine("Hello World!"); | |||||
| } | |||||
| } | |||||
| //public class ProgramHelloWorld | |||||
| //{ | |||||
| // public static async Task Main(string[] args) | |||||
| // { | |||||
| // var builder = new HostBuilder() | |||||
| // .ConfigureServices((hostContext, services) => | |||||
| // { | |||||
| // services.AddScoped<IHostedService, MyServiceA>(); | |||||
| // services.AddScoped<IHostedService, MyServiceB>(); | |||||
| // }); | |||||
| // await builder.RunConsoleAsync(); | |||||
| // } | |||||
| //} | |||||
| } | |||||
+ 6
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/Dockerfile
View File
| @ -0,0 +1,6 @@ | |||||
| FROM microsoft/aspnetcore:2.0 | |||||
| ARG source | |||||
| WORKDIR /app | |||||
| COPY ${source:-obj/Docker/publish} . | |||||
| ENTRYPOINT ["dotnet", "Ordering.BackgroundTasksWebHost.dll"] | |||||
+ 83
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/HostedServices/BackgroundService.cs
View File
| @ -0,0 +1,83 @@ | |||||
| using System; | |||||
| using System.Threading; | |||||
| using System.Threading.Tasks; | |||||
| using Microsoft.Extensions.Hosting; | |||||
| namespace Ordering.BackgroundTasksWebHost.HostedServices | |||||
| { | |||||
| // Copyright (c) .NET Foundation. All rights reserved. | |||||
| // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information. | |||||
| /// <summary> | |||||
| /// Base class for implementing a long running <see cref="IHostedService"/>. | |||||
| /// IMPORTANT: This base class is implemented in .NET Core 2.1 - Since this microservice is still in .NET Core 2.0, we're using the class within the project | |||||
| /// When .NET Core 2.1 is released, this class should be removed and you should use the use implemented by the framework | |||||
| /// https://github.com/aspnet/Hosting/blob/712c992ca827576c05923e6a134ca0bec87af4df/src/Microsoft.Extensions.Hosting.Abstractions/BackgroundService.cs | |||||
| /// | |||||
| /// </summary> | |||||
| public abstract class BackgroundService : IHostedService, IDisposable | |||||
| { | |||||
| private Task _executingTask; | |||||
| private readonly CancellationTokenSource _stoppingCts = new CancellationTokenSource(); | |||||
| /// <summary> | |||||
| /// This method is called when the <see cref="IHostedService"/> starts. The implementation should return a task that represents | |||||
| /// the lifetime of the long running operation(s) being performed. | |||||
| /// </summary> | |||||
| /// <param name="stoppingToken">Triggered when <see cref="IHostedService.StopAsync(CancellationToken)"/> is called.</param> | |||||
| /// <returns>A <see cref="Task"/> that represents the long running operations.</returns> | |||||
| protected abstract Task ExecuteAsync(CancellationToken stoppingToken); | |||||
| /// <summary> | |||||
| /// Triggered when the application host is ready to start the service. | |||||
| /// </summary> | |||||
| /// <param name="cancellationToken">Indicates that the start process has been aborted.</param> | |||||
| public virtual Task StartAsync(CancellationToken cancellationToken) | |||||
| { | |||||
| // Store the task we're executing | |||||
| _executingTask = ExecuteAsync(_stoppingCts.Token); | |||||
| // If the task is completed then return it, this will bubble cancellation and failure to the caller | |||||
| if (_executingTask.IsCompleted) | |||||
| { | |||||
| return _executingTask; | |||||
| } | |||||
| // Otherwise it's running | |||||
| return Task.CompletedTask; | |||||
| } | |||||
| /// <summary> | |||||
| /// Triggered when the application host is performing a graceful shutdown. | |||||
| /// </summary> | |||||
| /// <param name="cancellationToken">Indicates that the shutdown process should no longer be graceful.</param> | |||||
| public virtual async Task StopAsync(CancellationToken cancellationToken) | |||||
| { | |||||
| // Stop called without start | |||||
| if (_executingTask == null) | |||||
| { | |||||
| return; | |||||
| } | |||||
| try | |||||
| { | |||||
| // Signal cancellation to the executing method | |||||
| _stoppingCts.Cancel(); | |||||
| } | |||||
| finally | |||||
| { | |||||
| // Wait until the task completes or the stop token triggers | |||||
| await Task.WhenAny(_executingTask, Task.Delay(Timeout.Infinite, cancellationToken)); | |||||
| } | |||||
| } | |||||
| public virtual void Dispose() | |||||
| { | |||||
| _stoppingCts.Cancel(); | |||||
| } | |||||
| } | |||||
| } | |||||
+ 94
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/HostedServices/GracePeriodManagerService.cs
View File
| @ -0,0 +1,94 @@ | |||||
| namespace Ordering.BackgroundTasksWebHost.HostedServices | |||||
| { | |||||
| using Microsoft.Extensions.Logging; | |||||
| using Microsoft.Extensions.Options; | |||||
| using System; | |||||
| using System.Collections.Generic; | |||||
| using System.Data.SqlClient; | |||||
| using System.Threading; | |||||
| using System.Threading.Tasks; | |||||
| //using Dapper; | |||||
| //using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions; | |||||
| //using Microsoft.eShopOnContainers.Services.Ordering.API; | |||||
| //using Ordering.API.Application.IntegrationEvents.Events; | |||||
| public class GracePeriodManagerService | |||||
| : BackgroundService | |||||
| { | |||||
| private readonly ILogger<GracePeriodManagerService> _logger; | |||||
| private readonly OrderingBackgroundSettings _settings; | |||||
| //private readonly IEventBus _eventBus; | |||||
| public GracePeriodManagerService(IOptions<OrderingBackgroundSettings> settings, | |||||
| //IEventBus eventBus, | |||||
| ILogger<GracePeriodManagerService> logger) | |||||
| { | |||||
| _logger = logger ?? throw new ArgumentNullException(nameof(logger)); | |||||
| //_eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus)); | |||||
| _settings = settings?.Value ?? throw new ArgumentNullException(nameof(settings)); | |||||
| } | |||||
| protected override async Task ExecuteAsync(CancellationToken stoppingToken) | |||||
| { | |||||
| _logger.LogDebug($"GracePeriodManagerService is starting."); | |||||
| stoppingToken.Register(() => _logger.LogDebug($"#1 GracePeriodManagerService background task is stopping.")); | |||||
| while (!stoppingToken.IsCancellationRequested) | |||||
| { | |||||
| _logger.LogDebug($"GracePeriodManagerService background task is doing background work."); | |||||
| //CheckConfirmedGracePeriodOrders(); | |||||
| await Task.Delay(_settings.CheckUpdateTime, stoppingToken); | |||||
| } | |||||
| _logger.LogDebug($"GracePeriodManagerService background task is stopping."); | |||||
| await Task.CompletedTask; | |||||
| } | |||||
| //private void CheckConfirmedGracePeriodOrders() | |||||
| //{ | |||||
| // _logger.LogDebug($"Checking confirmed grace period orders"); | |||||
| // var orderIds = GetConfirmedGracePeriodOrders(); | |||||
| // foreach (var orderId in orderIds) | |||||
| // { | |||||
| // var confirmGracePeriodEvent = new GracePeriodConfirmedIntegrationEvent(orderId); | |||||
| // _eventBus.Publish(confirmGracePeriodEvent); | |||||
| // } | |||||
| //} | |||||
| //private IEnumerable<int> GetConfirmedGracePeriodOrders() | |||||
| //{ | |||||
| // IEnumerable<int> orderIds = new List<int>(); | |||||
| // using (var conn = new SqlConnection(_settings.ConnectionString)) | |||||
| // { | |||||
| // try | |||||
| // { | |||||
| // conn.Open(); | |||||
| // orderIds = conn.Query<int>( | |||||
| // @"SELECT Id FROM [ordering].[orders] | |||||
| // WHERE DATEDIFF(minute, [OrderDate], GETDATE()) >= @GracePeriodTime | |||||
| // AND [OrderStatusId] = 1", | |||||
| // new { GracePeriodTime = _settings.GracePeriodTime }); | |||||
| // } | |||||
| // catch (SqlException exception) | |||||
| // { | |||||
| // _logger.LogCritical($"FATAL ERROR: Database connections could not be opened: {exception.Message}"); | |||||
| // } | |||||
| // } | |||||
| // return orderIds; | |||||
| //} | |||||
| } | |||||
| } | |||||
+ 18
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/Infrastructure/AutofacModules/ApplicationModule.cs
View File
| @ -0,0 +1,18 @@ | |||||
| using Autofac; | |||||
| namespace Ordering.BackgroundTasksWebHost.Infrastructure.AutofacModules | |||||
| { | |||||
| public class ApplicationModule | |||||
| :Autofac.Module | |||||
| { | |||||
| public ApplicationModule(string qconstr) | |||||
| { | |||||
| } | |||||
| protected override void Load(ContainerBuilder builder) | |||||
| { | |||||
| } | |||||
| } | |||||
| } | |||||
+ 27
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/Ordering.BackgroundTasksWebHost.csproj
View File
| @ -0,0 +1,27 @@ | |||||
| <Project Sdk="Microsoft.NET.Sdk"> | |||||
| <PropertyGroup> | |||||
| <OutputType>Exe</OutputType> | |||||
| <TargetFramework>netcoreapp2.0</TargetFramework> | |||||
| </PropertyGroup> | |||||
| <ItemGroup> | |||||
| <None Remove="settings.json" /> | |||||
| </ItemGroup> | |||||
| <ItemGroup> | |||||
| <Content Include="settings.json"> | |||||
| <CopyToPublishDirectory>PreserveNewest</CopyToPublishDirectory> | |||||
| </Content> | |||||
| </ItemGroup> | |||||
| <ItemGroup> | |||||
| <PackageReference Include="Autofac.Extensions.DependencyInjection"> | |||||
| <Version>4.2.0</Version> | |||||
| </PackageReference> | |||||
| <PackageReference Include="Microsoft.AspNetCore.All"> | |||||
| <Version>2.0.3</Version> | |||||
| </PackageReference> | |||||
| </ItemGroup> | |||||
| </Project> | |||||
+ 13
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/OrderingBackgroundSettings.cs
View File
| @ -0,0 +1,13 @@ | |||||
| namespace Ordering.BackgroundTasksWebHost | |||||
| { | |||||
| public class OrderingBackgroundSettings | |||||
| { | |||||
| public string ConnectionString { get; set; } | |||||
| public string EventBusConnection { get; set; } | |||||
| public int GracePeriodTime { get; set; } | |||||
| public int CheckUpdateTime { get; set; } | |||||
| } | |||||
| } | |||||
+ 37
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/Program.cs
View File
| @ -0,0 +1,37 @@ | |||||
| using Microsoft.AspNetCore; | |||||
| using Microsoft.AspNetCore.Hosting; | |||||
| using Microsoft.Extensions.Configuration; | |||||
| using Microsoft.Extensions.DependencyInjection; | |||||
| using Microsoft.Extensions.Logging; | |||||
| using Microsoft.Extensions.Options; | |||||
| using System.IO; | |||||
| namespace Ordering.BackgroundTasksWebHost | |||||
| { | |||||
| public class Program | |||||
| { | |||||
| public static void Main(string[] args) | |||||
| { | |||||
| BuildWebHost(args).Run(); | |||||
| } | |||||
| public static IWebHost BuildWebHost(string[] args) => | |||||
| WebHost.CreateDefaultBuilder(args) | |||||
| .UseStartup<Startup>() | |||||
| //.UseHealthChecks("/hc") | |||||
| .UseContentRoot(Directory.GetCurrentDirectory()) | |||||
| .ConfigureAppConfiguration((builderContext, config) => | |||||
| { | |||||
| config.AddJsonFile("settings.json"); | |||||
| config.AddEnvironmentVariables(); | |||||
| }) | |||||
| .ConfigureLogging((hostingContext, builder) => | |||||
| { | |||||
| builder.AddConfiguration(hostingContext.Configuration.GetSection("Logging")); | |||||
| builder.AddConsole(); | |||||
| builder.AddDebug(); | |||||
| }) | |||||
| //.UseApplicationInsights() | |||||
| .Build(); | |||||
| } | |||||
| } | |||||
+ 219
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/Startup.cs
View File
| @ -0,0 +1,219 @@ | |||||
| using System; | |||||
| using Microsoft.Extensions.Configuration; | |||||
| using Microsoft.Extensions.DependencyInjection; | |||||
| using Autofac; | |||||
| using Autofac.Extensions.DependencyInjection; | |||||
| using Microsoft.ApplicationInsights.Extensibility; | |||||
| using Microsoft.AspNetCore.Builder; | |||||
| using Microsoft.AspNetCore.Hosting; | |||||
| //using Microsoft.eShopOnContainers.BuildingBlocks.EventBus; | |||||
| //using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions; | |||||
| //using Microsoft.eShopOnContainers.BuildingBlocks.EventBusRabbitMQ; | |||||
| //using Microsoft.eShopOnContainers.BuildingBlocks.EventBusServiceBus; | |||||
| using Microsoft.Extensions.Hosting; | |||||
| using Microsoft.Extensions.Logging; | |||||
| using System.Collections.Generic; | |||||
| using System.Data.Common; | |||||
| //using Microsoft.ApplicationInsights.ServiceFabric; | |||||
| //using RabbitMQ.Client; | |||||
| //using Microsoft.Azure.ServiceBus; | |||||
| //using Microsoft.Extensions.HealthChecks; | |||||
| //using Ordering.BackgroundTasksWebHost.Application.IntegrationEvents; | |||||
| //using Ordering.BackgroundTasksWebHost.Application.IntegrationEvents.Events; | |||||
| using Ordering.BackgroundTasksWebHost.Infrastructure.AutofacModules; | |||||
| using Ordering.BackgroundTasksWebHost.HostedServices; | |||||
| //using Ordering.BackgroundTasksWebHost.HostedServices; | |||||
| namespace Ordering.BackgroundTasksWebHost | |||||
| { | |||||
| public class Startup | |||||
| { | |||||
| public Startup(IConfiguration configuration) | |||||
| { | |||||
| Configuration = configuration; | |||||
| } | |||||
| public IConfiguration Configuration { get; } | |||||
| public IServiceProvider ConfigureServices(IServiceCollection services) | |||||
| { | |||||
| //RegisterAppInsights(services); | |||||
| // Configure GracePeriodManager Hosted Service | |||||
| services.AddSingleton<IHostedService, GracePeriodManagerService>(); | |||||
| //services.AddTransient<IOrderingIntegrationEventService, OrderingIntegrationEventService>(); | |||||
| //services.AddHealthChecks(checks => | |||||
| //{ | |||||
| // var minutes = 1; | |||||
| // if (int.TryParse(Configuration["HealthCheck:Timeout"], out var minutesParsed)) | |||||
| // { | |||||
| // minutes = minutesParsed; | |||||
| // } | |||||
| // checks.AddSqlCheck("OrderingDb", Configuration["ConnectionString"], TimeSpan.FromMinutes(minutes)); | |||||
| //}); | |||||
| services.Configure<OrderingBackgroundSettings>(Configuration); | |||||
| // Add application services. | |||||
| //services.AddTransient<IOrderingIntegrationEventService, OrderingIntegrationEventService>(); | |||||
| //if (Configuration.GetValue<bool>("AzureServiceBusEnabled")) | |||||
| //{ | |||||
| // services.AddSingleton<IServiceBusPersisterConnection>(sp => | |||||
| // { | |||||
| // var logger = sp.GetRequiredService<ILogger<DefaultServiceBusPersisterConnection>>(); | |||||
| // var serviceBusConnectionString = Configuration["EventBusConnection"]; | |||||
| // var serviceBusConnection = new ServiceBusConnectionStringBuilder(serviceBusConnectionString); | |||||
| // return new DefaultServiceBusPersisterConnection(serviceBusConnection, logger); | |||||
| // }); | |||||
| //} | |||||
| //else | |||||
| //{ | |||||
| // services.AddSingleton<IRabbitMQPersistentConnection>(sp => | |||||
| // { | |||||
| // var logger = sp.GetRequiredService<ILogger<DefaultRabbitMQPersistentConnection>>(); | |||||
| // var factory = new ConnectionFactory() | |||||
| // { | |||||
| // HostName = Configuration["EventBusConnection"] | |||||
| // }; | |||||
| // if (!string.IsNullOrEmpty(Configuration["EventBusUserName"])) | |||||
| // { | |||||
| // factory.UserName = Configuration["EventBusUserName"]; | |||||
| // } | |||||
| // if (!string.IsNullOrEmpty(Configuration["EventBusPassword"])) | |||||
| // { | |||||
| // factory.Password = Configuration["EventBusPassword"]; | |||||
| // } | |||||
| // var retryCount = 5; | |||||
| // if (!string.IsNullOrEmpty(Configuration["EventBusRetryCount"])) | |||||
| // { | |||||
| // retryCount = int.Parse(Configuration["EventBusRetryCount"]); | |||||
| // } | |||||
| // return new DefaultRabbitMQPersistentConnection(factory, logger, retryCount); | |||||
| // }); | |||||
| //} | |||||
| //RegisterEventBus(services); | |||||
| services.AddOptions(); | |||||
| //Configure autofac | |||||
| var container = new ContainerBuilder(); | |||||
| container.Populate(services); | |||||
| container.RegisterModule(new ApplicationModule(Configuration["ConnectionString"])); | |||||
| return new AutofacServiceProvider(container.Build()); | |||||
| } | |||||
| public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory) | |||||
| { | |||||
| loggerFactory.AddConsole(Configuration.GetSection("Logging")); | |||||
| loggerFactory.AddDebug(); | |||||
| //loggerFactory.AddAzureWebAppDiagnostics(); | |||||
| //loggerFactory.AddApplicationInsights(app.ApplicationServices, LogLevel.Trace); | |||||
| var pathBase = Configuration["PATH_BASE"]; | |||||
| if (!string.IsNullOrEmpty(pathBase)) | |||||
| { | |||||
| loggerFactory.CreateLogger("init").LogDebug($"Using PATH BASE '{pathBase}'"); | |||||
| app.UsePathBase(pathBase); | |||||
| } | |||||
| //ConfigureEventBus(app); | |||||
| } | |||||
| //private void RegisterAppInsights(IServiceCollection services) | |||||
| //{ | |||||
| // services.AddApplicationInsightsTelemetry(Configuration); | |||||
| // var orchestratorType = Configuration.GetValue<string>("OrchestratorType"); | |||||
| // if (orchestratorType?.ToUpper() == "K8S") | |||||
| // { | |||||
| // // Enable K8s telemetry initializer | |||||
| // services.EnableKubernetes(); | |||||
| // } | |||||
| // if (orchestratorType?.ToUpper() == "SF") | |||||
| // { | |||||
| // // Enable SF telemetry initializer | |||||
| // services.AddSingleton<ITelemetryInitializer>((serviceProvider) => | |||||
| // new FabricTelemetryInitializer()); | |||||
| // } | |||||
| //} | |||||
| //private void ConfigureEventBus(IApplicationBuilder app) | |||||
| //{ | |||||
| // var eventBus = app.ApplicationServices.GetRequiredService<BuildingBlocks.EventBus.Abstractions.IEventBus>(); | |||||
| // eventBus.Subscribe<UserCheckoutAcceptedIntegrationEvent, IIntegrationEventHandler<UserCheckoutAcceptedIntegrationEvent>>(); | |||||
| // eventBus.Subscribe<GracePeriodConfirmedIntegrationEvent, IIntegrationEventHandler<GracePeriodConfirmedIntegrationEvent>>(); | |||||
| // eventBus.Subscribe<OrderStockConfirmedIntegrationEvent, IIntegrationEventHandler<OrderStockConfirmedIntegrationEvent>>(); | |||||
| // eventBus.Subscribe<OrderStockRejectedIntegrationEvent, IIntegrationEventHandler<OrderStockRejectedIntegrationEvent>>(); | |||||
| // eventBus.Subscribe<OrderPaymentFailedIntegrationEvent, IIntegrationEventHandler<OrderPaymentFailedIntegrationEvent>>(); | |||||
| // eventBus.Subscribe<OrderPaymentSuccededIntegrationEvent, IIntegrationEventHandler<OrderPaymentSuccededIntegrationEvent>>(); | |||||
| //} | |||||
| //private void RegisterEventBus(IServiceCollection services) | |||||
| //{ | |||||
| // var subscriptionClientName = Configuration["SubscriptionClientName"]; | |||||
| // if (Configuration.GetValue<bool>("AzureServiceBusEnabled")) | |||||
| // { | |||||
| // services.AddSingleton<IEventBus, EventBusServiceBus>(sp => | |||||
| // { | |||||
| // var serviceBusPersisterConnection = sp.GetRequiredService<IServiceBusPersisterConnection>(); | |||||
| // var iLifetimeScope = sp.GetRequiredService<ILifetimeScope>(); | |||||
| // var logger = sp.GetRequiredService<ILogger<EventBusServiceBus>>(); | |||||
| // var eventBusSubcriptionsManager = sp.GetRequiredService<IEventBusSubscriptionsManager>(); | |||||
| // return new EventBusServiceBus(serviceBusPersisterConnection, logger, | |||||
| // eventBusSubcriptionsManager, subscriptionClientName, iLifetimeScope); | |||||
| // }); | |||||
| // } | |||||
| // else | |||||
| // { | |||||
| // services.AddSingleton<IEventBus, EventBusRabbitMQ>(sp => | |||||
| // { | |||||
| // var rabbitMQPersistentConnection = sp.GetRequiredService<IRabbitMQPersistentConnection>(); | |||||
| // var iLifetimeScope = sp.GetRequiredService<ILifetimeScope>(); | |||||
| // var logger = sp.GetRequiredService<ILogger<EventBusRabbitMQ>>(); | |||||
| // var eventBusSubcriptionsManager = sp.GetRequiredService<IEventBusSubscriptionsManager>(); | |||||
| // var retryCount = 5; | |||||
| // if (!string.IsNullOrEmpty(Configuration["EventBusRetryCount"])) | |||||
| // { | |||||
| // retryCount = int.Parse(Configuration["EventBusRetryCount"]); | |||||
| // } | |||||
| // return new EventBusRabbitMQ(rabbitMQPersistentConnection, logger, iLifetimeScope, eventBusSubcriptionsManager, subscriptionClientName, retryCount); | |||||
| // }); | |||||
| // } | |||||
| // services.AddSingleton<IEventBusSubscriptionsManager, InMemoryEventBusSubscriptionsManager>(); | |||||
| //} | |||||
| } | |||||
| } | |||||
+ 19
- 0
src/Services/Ordering/Ordering.BackgroundTasksWebHost/settings.json
View File
| @ -0,0 +1,19 @@ | |||||
| { | |||||
| "ConnectionString": "Server=tcp:127.0.0.1,5433;Database=Microsoft.eShopOnContainers.Services.OrderingDb;User Id=sa;Password=Pass@word;", | |||||
| "Logging": { | |||||
| "IncludeScopes": false, | |||||
| "LogLevel": { | |||||
| "Default": "Trace", | |||||
| "System": "Information", | |||||
| "Microsoft": "Information" | |||||
| } | |||||
| }, | |||||
| "AzureServiceBusEnabled": false, | |||||
| "SubscriptionClientName": "Ordering", | |||||
| "GracePeriodTime": "1", | |||||
| "CheckUpdateTime": "30000", | |||||
| "ApplicationInsights": { | |||||
| "InstrumentationKey": "" | |||||
| }, | |||||
| "EventBusRetryCount": 5 | |||||
| } | |||||