public function getReplies()
    {
        $this->channel
            ->basic_consume(
                $this->queueName,
                $this->queueName,
                false,
                true,
                false,
                false,
                array($this, 'processMessage')
            );

        while (count($this->replies) < $this->requests) {
            $this->channel
                ->wait(null, false, $this->requestTimeout);
        }

        $this->channel
            ->basic_cancel($this->queueName);

        return $this->replies;
    }
public function getReplies()
    {
        $this->channel
            ->basic_consume(
                $this->queueName,
                $this->queueName,
                false,
                true,
                false,
                false,
                array($this, 'processMessage')
            );

        while (count($this->replies) < $this->requests) {
            $this->channel
                ->wait(null, false, $this->requestTimeout);
        }

        $this->channel
            ->basic_cancel($this->queueName);

        return $this->replies;
    }
public function getReplies ( ) { $ this -> channel -> basic_consume ( $ this -> queueName , $ this -> queueName , false , true , false , false , array ( $ this , 'processMessage' ) ) ; while ( count ( $ this -> replies ) < $ this -> requests ) { $ this -> channel -> wait ( null , false , $ this -> requestTimeout ) ; } $ this -> channel -> basic_cancel ( $ this -> queueName ) ; return $ this -> replies ; }
Get replies.

@return array
Get replies .