From 80793c87f0bd26dabe5a1865bd3be711042a51a9 Mon Sep 17 00:00:00 2001
From: YongHun Byun <yonghunbyun@gmail.com>
Date: Tue, 7 Jul 2015 00:11:07 +0900
Subject: [PATCH] Fix the missing commit error

---
 src/AsyncQueue.php | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/AsyncQueue.php b/src/AsyncQueue.php
index cffc5bd..f9ed5d1 100644
--- a/src/AsyncQueue.php
+++ b/src/AsyncQueue.php
@@ -118,11 +118,15 @@ public function getJobFromId($queue, $id)
                     
         if($job) {
             $this->markJobAsReserved($job->id);
+
+            $this->database->commit();
             
 			return new DatabaseJob(
 				$this->container, $this, $job, $queue
 			);
         }
+
+        $this->database->commit();
 	}
 
     /**