Commit bd354d87 authored by Jens Segers's avatar Jens Segers

Forgot to disable transaction

parent df5e3a10
...@@ -13,13 +13,20 @@ class MongoQueue extends DatabaseQueue ...@@ -13,13 +13,20 @@ class MongoQueue extends DatabaseQueue
*/ */
protected function getNextAvailableJob($queue) protected function getNextAvailableJob($queue)
{ {
$job = parent::getNextAvailableJob($queue); $job = $this->database->table($this->table)
->lockForUpdate()
->where('queue', $this->getQueue($queue))
->where('reserved', 0)
->where('available_at', '<=', $this->getTime())
->orderBy('id', 'asc')
->first();
if ($job) { if ($job) {
$job = (object) $job;
$job->id = $job->_id; $job->id = $job->_id;
} }
return $job; return $job ?: null;
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment