reset replies for subsequent requests

nail · nail · commit 8f7b00b96a28 · 2014-02-18T18:38:03.000+01:00
diff --git a/RabbitMq/RpcClient.php b/RabbitMq/RpcClient.php
@@ -41,8 +41,10 @@ public function getReplies()
 
         $this->getChannel()->basic_cancel($this->queueName);
         $this->requests = 0;
+        $replies = $this->replies;
+        $this->replies = array();
 
-        return $this->replies;
+        return $replies;
     }
 
     public function processMessage(AMQPMessage $msg)

Original file line number	Diff line number	Diff line change
`@@ -41,8 +41,10 @@ public function getReplies()`
`41`	`41`
`42`	`42`	`$this->getChannel()->basic_cancel($this->queueName);`
`43`	`43`	`$this->requests = 0;`
	`44`	`+ $replies = $this->replies;`
	`45`	`+ $this->replies = array();`
`44`	`46`
`45`		`- return $this->replies;`
	`47`	`+ return $replies;`
`46`	`48`	`}`
`47`	`49`
`48`	`50`	`public function processMessage(AMQPMessage $msg)`