public function getQueueId($name)
    {
        $sql = 'SELECT queue_id FROM ' . $this->queueTable . ' WHERE queue_name = ? LIMIT 1';
        $stmt = $this->getDb()->prepare($sql);
        $stmt->execute(array($name));
        return $stmt->fetchColumn();
    }