【发布时间】:2016-09-06 20:39:05
【问题描述】:
我将 Hangfire 1.6.4 用于我的 .NET Core 项目。
这是我的调度控制器:
[HttpPost]
public void Post([FromBody]EmailSchedulerDto emailSchedulerDto)
{
// test only
emailSchedulerDto = new EmailSchedulerDto
{
UserId = "",
Email = "myEmail@gmail.com",
StoresId = new List<string>(),
CronPattern = "* * * * *"
};
RecurringJob.AddOrUpdate(
() =>
_emailScheduler.ScheduleEmail(emailSchedulerDto.UserId, emailSchedulerDto.Email,
emailSchedulerDto.StoresId), emailSchedulerDto.CronPattern);
}
但我在作业执行过程中出错:
// Job ID: #183
using MyProject.Services.Email;
var emailScheduler = Activate<EmailScheduler>();
await emailScheduler.ScheduleEmail(
"",
"myEmail@gmail.com",
FromJson<IEnumerable`1>("[]")
storesId
);
System.InvalidOperationException
没有注册类型“MyProject.Services.Email.EmailScheduler”的服务。
我已经像这样注册了 ContainerJobActivator:
public class ContainerJobActivator : JobActivator
{
private readonly IServiceProvider _serviceProvider;
public ContainerJobActivator(IServiceProvider serviceProvider)
{
_serviceProvider = serviceProvider;
}
public override object ActivateJob(Type type)
{
return _serviceProvider.GetService(type);
}
}
在 Startup 类中:
GlobalConfiguration.Configuration.UseActivator(new ContainerJobActivator(services.BuildServiceProvider()));
怎么了?
谢谢!
【问题讨论】:
标签: .net asp.net-core-mvc hangfire