diff --git a/src/Concerns/InteractsWithWebsocket.php b/src/Concerns/InteractsWithWebsocket.php index 1292447..41adc3a 100644 --- a/src/Concerns/InteractsWithWebsocket.php +++ b/src/Concerns/InteractsWithWebsocket.php @@ -136,9 +136,11 @@ public function onMessage($server, $frame) // dispatch message to registered event callback ['event' => $event, 'data' => $data] = $payload; - $websocket->eventExists($event) - ? $websocket->call($event, $data) - : $this->websocketHandler->onMessage($frame); + if ($event and $websocket->eventExists($event)) { + $websocket->call($event, $data); + } else { + $this->websocketHandler->onMessage($frame); + } } catch (Throwable $e) { $this->logServerError($e); } finally {