diff --git a/src/Bernard/Driver/DoctrineDriver.php b/src/Bernard/Driver/DoctrineDriver.php index bece2611..afb2bf1a 100644 --- a/src/Bernard/Driver/DoctrineDriver.php +++ b/src/Bernard/Driver/DoctrineDriver.php @@ -69,8 +69,9 @@ public function createQueue($queueName) */ public function countMessages($queueName) { - return $this->connection->fetchColumn('SELECT COUNT(id) FROM bernard_messages WHERE queue = :queue AND visible = 1', array( + return $this->connection->fetchColumn('SELECT COUNT(id) FROM bernard_messages WHERE queue = :queue AND visible = :visible', array( 'queue' => $queueName, + 'visible' => true, )); }