diff --git a/src/Websocket/Handler.php b/src/Websocket/Handler.php
index b5b180a..ac7797e 100644
--- a/src/Websocket/Handler.php
+++ b/src/Websocket/Handler.php
@@ -153,6 +153,7 @@ class Handler implements MessageComponentInterface
                 Log::error('Fork error');
             } elseif ($pid == 0) {
                 try {
+                    DB::disconnect();
                     DB::reconnect();
 
                     $this->setRequest($message, $connection);