Merge pull request #348 from sterrien/patch-1

skafandri · skafandri · commit 9a52d55adc02 · 2016-04-29T12:09:25.000+03:00
Force fetching new channel when channel_id is null
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`