lsm/Orchard
1
0
Fork 0
mirror of https://github.com/OrchardCMS/Orchard.git synced 2025-10-15 19:54:57 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Merge pull request #6002 from jtkech/patch-3

Browse Source 
[Fixes #5882] No record could be found in the database for lock
This commit is contained in:
Sébastien Ros
2015-11-10 12:57:15 -08:00
parent d0f8fcdcf7 b6adf43b5d
commit adc92fb1b4
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/Orchard.Web/Modules/Orchard.JobsQueue/Services/JobsQueueProcessor.cs
View File

@@ -12,12 +12,12 @@ namespace Orchard.JobsQueue.Services {
public class JobsQueueProcessor : IJobsQueueProcessor {
private readonly Work<IJobsQueueManager> _jobsQueueManager;
private readonly Work<IEventBus> _eventBus;
private readonly IDistributedLockService _distributedLockService;
private readonly Work<IDistributedLockService> _distributedLockService;
public JobsQueueProcessor(
Work<IJobsQueueManager> jobsQueueManager,
Work<IEventBus> eventBus,
IDistributedLockService distributedLockService) {
Work<IDistributedLockService> distributedLockService) {
_jobsQueueManager = jobsQueueManager;
_eventBus = eventBus;
@@ -29,7 +29,7 @@ namespace Orchard.JobsQueue.Services {
public void ProcessQueue() {
IDistributedLock @lock;
if (_distributedLockService.TryAcquireLock(GetType().FullName, TimeSpan.FromMinutes(5), out @lock)) {
if (_distributedLockService.Value.TryAcquireLock(GetType().FullName, TimeSpan.FromMinutes(5), out @lock)) {
using (@lock) {
IEnumerable<QueuedJobRecord> messages;
@@ -88,4 +88,4 @@ namespace Orchard.JobsQueue.Services {
}
}
}
}
}