@@ -1,15 +1,12 @@
|
||||
using LiteCharms.Features.Extensions;
|
||||
using LiteCharms.Features.Mediator;
|
||||
using LiteCharms.Features.MidrandBooks.Extensions;
|
||||
using LiteCharmsScheduler.Workers;
|
||||
using static LiteCharms.Features.Email.Extensions.Constants;
|
||||
using static LiteCharms.Features.Extensions.Quartz;
|
||||
|
||||
var builder = Host.CreateApplicationBuilder(args);
|
||||
|
||||
builder.Services.AddMediator(options => options.Assemblies = new List<AssemblyReference>
|
||||
{
|
||||
typeof(Program).Assembly,
|
||||
typeof(LiteCharms.Features.Shop.Notifications.Events.ProcessEmailNotificationsEvent).Assembly
|
||||
}.AsReadOnly());
|
||||
builder.Services.AddMediator();
|
||||
|
||||
builder.Services.AddScoped(typeof(IPipelineBehavior<,>), typeof(TelemetryPipelineBehavior<,>));
|
||||
builder.Services.AddScoped(typeof(IPipelineBehavior<,>), typeof(LoggingPipelineBehavior<,>));
|
||||
@@ -17,19 +14,18 @@ builder.Services.AddScoped(typeof(IPipelineBehavior<,>), typeof(LoggingPipelineB
|
||||
builder.Services.AddEmailServices(builder.Configuration);
|
||||
builder.Services.AddEmailServiceBus();
|
||||
|
||||
builder.Services.AddSalesServiceBus();
|
||||
builder.Services.AddGeneralServiceBus();
|
||||
builder.Services.AddQuartzScheduler(ShopSchedulerName, builder.Configuration);
|
||||
|
||||
builder.Services.AddShopServices();
|
||||
builder.Services.AddShopDatabase(builder.Configuration);
|
||||
builder.Services.AddHashServices(builder.Configuration);
|
||||
builder.Services.AddMidrandShopDatabase(builder.Configuration);
|
||||
|
||||
builder.Services.AddQuartzScheduler(MidrandShopSchedulerName, builder.Configuration);
|
||||
|
||||
builder.Services.AddHostedService<JobWorker>();
|
||||
|
||||
var host = builder.Build();
|
||||
|
||||
var schedulerFactory = host.Services.GetRequiredService<ISchedulerFactory>();
|
||||
var scheduler = await schedulerFactory.GetScheduler(ShopSchedulerName);
|
||||
var scheduler = await schedulerFactory.GetScheduler(MidrandShopSchedulerName);
|
||||
|
||||
if (!scheduler!.IsStarted)
|
||||
await scheduler.Start();
|
||||
|
||||
Reference in New Issue
Block a user