Force fetching new channel when channel_id is null

sterrien · sterrien · commit 254125a5641f · 2016-04-07T15:29:31.000+02:00
Fix #347
diff --git a/RabbitMq/BaseAmqp.php b/RabbitMq/BaseAmqp.php
@@ -80,7 +80,7 @@ public function reconnect()
      */
     public function getChannel()
     {
-        if (empty($this->ch)) {
+        if (empty($this->ch) || null === $this->ch->getChannelId()) {
             $this->ch = $this->conn->channel();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ public function reconnect()`
`80`	`80`	`*/`
`81`	`81`	`public function getChannel()`
`82`	`82`	`{`
`83`		`- if (empty($this->ch)) {`
	`83`	`+ if (empty($this->ch) \|\| null === $this->ch->getChannelId()) {`
`84`	`84`	`$this->ch = $this->conn->channel();`
`85`	`85`	`}`
`86`	`86`