diff --git a/src/WebSockets/WebSocketHandler.php b/src/WebSockets/WebSocketHandler.php index 0f00342..f99e0be 100644 --- a/src/WebSockets/WebSocketHandler.php +++ b/src/WebSockets/WebSocketHandler.php @@ -153,6 +153,7 @@ class WebSocketHandler implements MessageComponentInterface { if (! is_null($capacity = $connection->app->capacity)) { $connectionsCount = $this->channelManager->getConnectionCount($connection->app->id); + if ($connectionsCount >= $capacity) { throw new ConnectionsOverCapacity(); }