Merge pull request #334 from MatthiasKuehneEllerhold/0.12.3-fix-limit…

…1FOR_UPDATE [0.x] DoctrineDriver: Fix "LIMIT 1FOR UPDATE"
bernardphp · Nov 5, 2017 · c452caa · c452caa
2 parents 01fcfad + b0d3efa
commit c452caa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Bernard/Driver/DoctrineDriver.php b/src/Bernard/Driver/DoctrineDriver.php
@@ -122,7 +122,7 @@ protected function doPopMessage($queueName)
     {
         $query = 'SELECT id, message FROM bernard_messages
                   WHERE queue = :queue AND visible = :visible
-                  ORDER BY sentAt, id LIMIT 1' . $this->connection->getDatabasePlatform()->getForUpdateSql();
+                  ORDER BY sentAt, id LIMIT 1 ' . $this->connection->getDatabasePlatform()->getForUpdateSql();
 
         list($id, $message) = $this->connection->fetchArray($query, array(
             'queue' => $queueName,