Browse Source

Update document

pull/10292/head
liangshiwei 4 years ago
parent
commit
4fdc2edbdc
  1. 5
      docs/en/Background-Workers-Hangfire.md
  2. 4
      docs/zh-Hans/Background-Workers-Hangfire.md
  3. 2
      framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfireBackgroundWorkerBase.cs
  4. 6
      framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfireBackgroundWorkerManager.cs
  5. 2
      framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfirePeriodicBackgroundWorkerAdapter.cs
  6. 2
      framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/IHangfireBackgroundWorker.cs

5
docs/en/Background-Workers-Hangfire.md

@ -44,14 +44,13 @@ public class YourModule : AbpModule
`HangfireBackgroundWorkerBase` is an easy way to create a background worker.
```` csharp
```` csharp
public class MyLogWorker : HangfireBackgroundWorkerBase
{
public MyLogWorker()
{
RecurringJobId = nameof(MyLogWorker);
CronExpression = Cron.Hourly(5);
CronExpression = Cron.Daily();
}
public override Task DoWorkAsync()
@ -91,7 +90,7 @@ context.ServiceProvider
.Add(
context
.ServiceProvider
.GetRequiredService<PassiveUserCheckerWorker>()
.GetRequiredService<MyLogWorker>()
);
````

4
docs/zh-Hans/Background-Workers-Hangfire.md

@ -51,7 +51,7 @@ public class MyLogWorker : HangfireBackgroundWorkerBase
public MyLogWorker()
{
RecurringJobId = nameof(MyLogWorker);
CronExpression = Cron.Hourly(5);
CronExpression = Cron.Daily();
}
public override Task DoWorkAsync()
@ -91,7 +91,7 @@ context.ServiceProvider
.Add(
context
.ServiceProvider
.GetRequiredService<PassiveUserCheckerWorker>()
.GetRequiredService<MyLogWorker>()
);
````

2
framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfireBackgroundWorkerBase.cs

@ -8,6 +8,6 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
public string CronExpression { get; set; }
public abstract Task ExecuteAsync();
public abstract Task DoWorkAsync();
}
}

6
framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfireBackgroundWorkerManager.cs

@ -27,12 +27,12 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
{
if (hangfireBackgroundWorker.RecurringJobId.IsNullOrWhiteSpace())
{
RecurringJob.AddOrUpdate(() => hangfireBackgroundWorker.ExecuteAsync(),
RecurringJob.AddOrUpdate(() => hangfireBackgroundWorker.DoWorkAsync(),
hangfireBackgroundWorker.CronExpression);
}
else
{
RecurringJob.AddOrUpdate(hangfireBackgroundWorker.RecurringJobId,() => hangfireBackgroundWorker.ExecuteAsync(),
RecurringJob.AddOrUpdate(hangfireBackgroundWorker.RecurringJobId,() => hangfireBackgroundWorker.DoWorkAsync(),
hangfireBackgroundWorker.CronExpression);
}
}
@ -59,7 +59,7 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
var adapterType = typeof(HangfirePeriodicBackgroundWorkerAdapter<>).MakeGenericType(worker.GetType());
var workerAdapter = Activator.CreateInstance(adapterType) as IHangfireBackgroundWorker;
RecurringJob.AddOrUpdate(() => workerAdapter.ExecuteAsync(), GetCron(period.Value));
RecurringJob.AddOrUpdate(() => workerAdapter.DoWorkAsync(), GetCron(period.Value));
}
}

2
framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/HangfirePeriodicBackgroundWorkerAdapter.cs

@ -17,7 +17,7 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
_doWorkMethod = typeof(TWorker).GetMethod("DoWork", BindingFlags.Instance | BindingFlags.NonPublic);
}
public override async Task ExecuteAsync()
public override async Task DoWorkAsync()
{
var workerContext = new PeriodicBackgroundWorkerContext(ServiceProvider);
var worker = ServiceProvider.GetRequiredService<TWorker>();

2
framework/src/Volo.Abp.BackgroundWorkers.Hangfire/Volo/Abp/BackgroundWorkers/Hangfire/IHangfireBackgroundWorker.cs

@ -8,7 +8,7 @@ namespace Volo.Abp.BackgroundWorkers.Hangfire
string CronExpression { get; set; }
Task ExecuteAsync();
Task DoWorkAsync();
}
}

Loading…
Cancel
Save