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;
    }
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;
    }
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 ; }
Add new message to queue

@param Message $message
@param string $name
@return bool
Add new message to queue