Merge pull request #37 from utopia-php/amqp-loop

fix(amqp): properly close connection on errors and open clean, new connection

Author: christyjacob4

src/Queue/Broker/AMQP.php

@@ -189,15 +189,16 @@ private function withChannel(callable $callback): void
             return $channel;
         };
 
-        if ($this->channel == null) {
+        if (!$this->channel) {
             $this->channel = $createChannel();
         }
 
         try {
             $callback($this->channel);
         } catch (\Throwable $th) {
-            // try to create a new connection once
-            unset($this->channel);
+            // createChannel() might throw, in that case set the channel to `null` first.
+            $this->channel = null;
+            // try creating a new connection once, if this still fails, throw the error
             $this->channel = $createChannel();
             $callback($this->channel);
         }