Skip to content

Commit d24e9c7

Browse files
committed
Get the new channel once we reconnect
1 parent 099864c commit d24e9c7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ public function pop($queue = null)
140140
$this->channel->close();
141141
$this->connector->reconnect();
142142
$this->connection = $this->connector->connection();
143-
$this->getChannel();
143+
$this->channel = $this->getChannel();
144144
}
145145

146146
return null;

0 commit comments

Comments
 (0)