aquire lock before deleting

laravel · May 18, 2016 · 4b502dc · 4b502dc
1 parent b4d6416
commit 4b502dc
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Illuminate/Queue/DatabaseQueue.php b/src/Illuminate/Queue/DatabaseQueue.php
@@ -253,7 +253,13 @@ protected function markJobAsReserved($id)
      */
     public function deleteReserved($queue, $id)
     {
-        $this->database->table($this->table)->where('id', $id)->delete();
+        $this->database->beginTransaction();
+
+        if ($this->database->table($this->table)->lockForUpdate()->find($id)) {
+            $this->database->table($this->table)->where('id', $id)->delete();
+        }
+
+        $this->database->commit();
     }
 
     /**