Updated as per @bastnic comment

nail · nail · commit e8de70319b2e · 2014-02-19T17:30:16.000+01:00
diff --git a/RabbitMq/RpcClient.php b/RabbitMq/RpcClient.php
@@ -33,6 +33,7 @@ public function addRequest($msgBody, $server, $requestId = null, $routingKey = '
 
     public function getReplies()
     {
+        $this->replies = array();
         $this->getChannel()->basic_consume($this->queueName, '', false, true, false, false, array($this, 'processMessage'));
 
         while (count($this->replies) < $this->requests) {
@@ -41,10 +42,8 @@ public function getReplies()
 
         $this->getChannel()->basic_cancel($this->queueName);
         $this->requests = 0;
-        $replies = $this->replies;
-        $this->replies = array();
 
-        return $replies;
+        return $this->replies;
     }
 
     public function processMessage(AMQPMessage $msg)

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,7 @@ public function addRequest($msgBody, $server, $requestId = null, $routingKey = '`
`33`	`33`
`34`	`34`	`public function getReplies()`
`35`	`35`	`{`
	`36`	`+ $this->replies = array();`
`36`	`37`	`$this->getChannel()->basic_consume($this->queueName, '', false, true, false, false, array($this, 'processMessage'));`
`37`	`38`
`38`	`39`	`while (count($this->replies) < $this->requests) {`
`@@ -41,10 +42,8 @@ public function getReplies()`
`41`	`42`
`42`	`43`	`$this->getChannel()->basic_cancel($this->queueName);`
`43`	`44`	`$this->requests = 0;`
`44`		`- $replies = $this->replies;`
`45`		`- $this->replies = array();`
`46`	`45`
`47`		`- return $replies;`
	`46`	`+ return $this->replies;`
`48`	`47`	`}`
`49`	`48`
`50`	`49`	`public function processMessage(AMQPMessage $msg)`