Browse Source

Improve Hangfire Initialization code

pull/22759/head
liangshiwei 10 months ago
parent
commit
d2a06b5f7c
  1. 9
      framework/src/Volo.Abp.BackgroundJobs.HangFire/Volo/Abp/BackgroundJobs/Hangfire/AbpBackgroundJobsHangfireModule.cs
  2. 12
      framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/AbpBackgroundWorkersHangfireModule.cs

9
framework/src/Volo.Abp.BackgroundJobs.HangFire/Volo/Abp/BackgroundJobs/Hangfire/AbpBackgroundJobsHangfireModule.cs

@ -25,13 +25,8 @@ public class AbpBackgroundJobsHangfireModule : AbpModule
if (!options.IsJobExecutionEnabled)
{
var hangfireOptions = context.ServiceProvider.GetRequiredService<IOptions<AbpHangfireOptions>>().Value;
hangfireOptions.BackgroundJobServerFactory = CreateOnlyEnqueueJobServer;
context.ServiceProvider.GetRequiredService<JobStorage>();
hangfireOptions.BackgroundJobServerFactory = _ => null;
}
}
private BackgroundJobServer? CreateOnlyEnqueueJobServer(IServiceProvider serviceProvider)
{
serviceProvider.GetRequiredService<JobStorage>();
return null;
}
}

12
framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/AbpBackgroundWorkersHangfireModule.cs

@ -1,5 +1,4 @@
using System;
using Hangfire;
using Hangfire;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
using Volo.Abp.Hangfire;
@ -23,17 +22,12 @@ public class AbpBackgroundWorkersHangfireModule : AbpModule
if (!options.IsEnabled)
{
var hangfireOptions = context.ServiceProvider.GetRequiredService<IOptions<AbpHangfireOptions>>().Value;
hangfireOptions.BackgroundJobServerFactory = CreateOnlyEnqueueJobServer;
context.ServiceProvider.GetRequiredService<JobStorage>();
hangfireOptions.BackgroundJobServerFactory = _ => null;
}
context.ServiceProvider
.GetRequiredService<HangfireBackgroundWorkerManager>()
.Initialize();
}
private BackgroundJobServer? CreateOnlyEnqueueJobServer(IServiceProvider serviceProvider)
{
serviceProvider.GetRequiredService<JobStorage>();
return null;
}
}

Loading…
Cancel
Save