Merge pull request #161 from syspay/rep-seq

videlalvaro · videlalvaro · commit d531fecd8d3d · 2014-02-20T16:21:00.000+01:00
reset replies for subsequent requests
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) {

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) {`