Skip to content

Commit d5e26ba

Browse files
committed
fix
1 parent 78baf59 commit d5e26ba

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

src/Protocols/Amqp.php

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -233,13 +233,11 @@ protected function reconnect(): bool
233233
{
234234
if ($this->connection) {
235235

236-
$queues = array_keys($this->queues);
237-
238236
if ($this->channel) {
239237
$this->channel->close();
240238
}
241239

242-
if ($this->queues) {
240+
if (!empty($this->queues)) {
243241
$queues = array_keys($this->queues);
244242
}
245243

0 commit comments

Comments
 (0)