Update Client.php

If RabbitMQ closed the connection due to incorrect login/password
viras777 · Nov 21, 2021 · 2751d4f · 2751d4f
1 parent e9f2ab5
commit 2751d4f
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/Bunny/Async/Client.php b/src/Bunny/Async/Client.php
@@ -297,7 +297,16 @@ public function addAwaitCallback(callable $callback)
      */
     public function onDataAvailable()
     {
-        $this->read();
+        try {
+            $this->read();
+        } catch (\Throwable $e) {
+            foreach ($this->awaitCallbacks as $k => $callback) {
+                if ($callback($e) === true) {
+                    unset($this->awaitCallbacks[$k]);
+                    break;
+                }
+            }
+        }
 
         while (($frame = $this->reader->consumeFrame($this->readBuffer)) !== null) {
             foreach ($this->awaitCallbacks as $k => $callback) {