diff --git a/src/Server/Messages/PusherMessageFactory.php b/src/Server/Messages/PusherMessageFactory.php
index cdd7dd1..e24e7dd 100644
--- a/src/Server/Messages/PusherMessageFactory.php
+++ b/src/Server/Messages/PusherMessageFactory.php
@@ -25,7 +25,7 @@ class PusherMessageFactory
     {
         $payload = json_decode($message->getPayload());
 
-        return Str::startsWith($payload->event, 'pusher:')
+        return Str::startsWith($payload->event, 'pusher.')
             ? new PusherChannelProtocolMessage($payload, $connection, $channelManager)
             : new PusherClientMessage($payload, $connection, $channelManager);
     }