public function addMessageToQueue(Message $message, $name)
    {
        $q      = $this->getQueue($name);
        $qid    = $this->getQueueId($q->getName());
        $body   = base64_encode(serialize($message));
        $md5    = md5($body);

        $sql = 'INSERT INTO ' . $this->messageTable . '
            (queue_id, body, created, timeout, md5)
            VALUES
            (:queue_id, :body, :created, :timeout, :md5)
            ';
        $stmt = $this->getDb()->prepare($sql);
        $stmt->bindParam(':queue_id', $qid, \PDO::PARAM_INT);
        $stmt->bindParam(':body', $body, \PDO::PARAM_STR);
        $stmt->bindParam(':md5', $md5, \PDO::PARAM_STR);
        $stmt->bindValue(':created', time(), \PDO::PARAM_INT);
        $stmt->bindValue(':timeout', 30, \PDO::PARAM_INT);
        $stmt->execute();
        return true;
    }