diff --git a/src/Orchard.Web/Modules/Orchard.JobsQueue/Services/JobsQueueProcessor.cs b/src/Orchard.Web/Modules/Orchard.JobsQueue/Services/JobsQueueProcessor.cs index 958ef89d0..dd5ddc633 100644 --- a/src/Orchard.Web/Modules/Orchard.JobsQueue/Services/JobsQueueProcessor.cs +++ b/src/Orchard.Web/Modules/Orchard.JobsQueue/Services/JobsQueueProcessor.cs @@ -15,14 +15,14 @@ namespace Orchard.JobsQueue.Services { private readonly Work _jobsQueueManager; private readonly Work _clock; private readonly Work _taskLeaseService; - private readonly IEventBus _eventBus; + private readonly Work _eventBus; private readonly ReaderWriterLockSlim _rwl = new ReaderWriterLockSlim(); public JobsQueueProcessor( Work clock, Work jobsQueueManager, Work taskLeaseService, - IEventBus eventBus) { + Work eventBus) { _clock = clock; _jobsQueueManager = jobsQueueManager; _taskLeaseService = taskLeaseService; @@ -59,7 +59,7 @@ namespace Orchard.JobsQueue.Services { var payload = JObject.Parse(job.Parameters); var parameters = payload.ToDictionary(); - _eventBus.Notify(job.Message, parameters); + _eventBus.Value.Notify(job.Message, parameters); Logger.Debug("Processed job Id {0}.", job.Id); }