diff --git a/src/Websocket/Controller.php b/src/Websocket/Controller.php
index 6dd91b1..df7d8a9 100644
--- a/src/Websocket/Controller.php
+++ b/src/Websocket/Controller.php
@@ -105,7 +105,7 @@ class Controller
             ]));
 
             return $payload;
-        } catch (\Exception $e) {
+        } catch (\Throwable $e) {
             $reload = [
                 'event' => @$message['event'],
                 'data' => @$message['data'],
diff --git a/src/Websocket/Handler.php b/src/Websocket/Handler.php
index 23ecf41..1591113 100644
--- a/src/Websocket/Handler.php
+++ b/src/Websocket/Handler.php
@@ -165,7 +165,7 @@ class Handler implements MessageComponentInterface
             } else {
                 $this->addDataCheckLoop($connection, $message, $pid);
             }
-        } catch (\Exception $e) {
+        } catch (\Throwable $e) {
             Log::channel('websocket')->error('onMessage unhandled error: '. $e->getMessage(), [
                 'file' => $e->getFile(),
                 'line' => $e->getLine(),
diff --git a/src/Websocket/MockConnection.php b/src/Websocket/MockConnection.php
index dcc8a23..7673e31 100644
--- a/src/Websocket/MockConnection.php
+++ b/src/Websocket/MockConnection.php
@@ -36,7 +36,7 @@ class MockConnection extends Connection implements \Ratchet\ConnectionInterface
             try {
                 $property->setAccessible(true);
                 $this->{$property->getName()} = $property->getValue($original_connection);
-            } catch (\Exception $e) {
+            } catch (\Throwable $e) {
             }
         }