[amqp-bunny] ignore broken pipe exception in __destruct()

php-enqueue · Oct 14, 2017 · 620031c · 620031c
1 parent 573ba54
commit 620031c
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/pkg/amqp-bunny/BunnyClient.php b/pkg/amqp-bunny/BunnyClient.php
@@ -9,10 +9,12 @@ class BunnyClient extends Client
 {
     public function __destruct()
     {
-//        try {
-        parent::__destruct();
-//        } catch (ClientException $e) {
-//            if ('' === $e->getMessage()
-//        }
+        try {
+            parent::__destruct();
+        } catch (ClientException $e) {
+            if ('Broken pipe or closed connection.' !== $e->getMessage()) {
+                throw $e;
+            }
+        }
     }
 }