Fix offset in DoctrineDriver peekQueue

bernardphp · Feb 4, 2014 · 50bc626 · 50bc626
1 parent c0628c3
commit 50bc626
Showing 1 changed file with 2 additions and 9 deletions.
diff --git a/src/Bernard/Driver/DoctrineDriver.php b/src/Bernard/Driver/DoctrineDriver.php
@@ -130,16 +130,9 @@ public function acknowledgeMessage($queueName, $receipt)
      */
     public function peekQueue($queueName, $index = 0, $limit = 20)
     {
-        $query = 'SELECT message FROM bernard_messages WHERE queue = ? LIMIT ?, ?';
-        $params = array(
-            $queueName,
-            $index,
-            $limit,
-        );
+        $query = 'SELECT message FROM bernard_messages WHERE queue = ? LIMIT ' . $index . ', ' . $limit;
 
-        $statement = $this->connection->executeQuery($query, $params, array(
-            'string', 'integer', 'integer'
-        ));
+        $statement = $this->connection->executeQuery($query, array($queueName));
 
         return $statement->fetchAll(\PDO::FETCH_COLUMN);
     }