diff --git a/app/realtime.php b/app/realtime.php
index 7e8e35e933..41c4be6637 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -1020,7 +1020,6 @@ $server->onMessage(function (int $connection, string $message) use ($server, $re
                     $subscriptionId = $parsedPayload['subscriptionId'];
                     $channels = \array_keys(Realtime::convertChannels($parsedPayload['channels'], $userId));
                     $queries = $parsedPayload['queries'];
-                    $realtime->removeSubscriptionForConnection($projectId, $connection, $subscriptionId);
                     $realtime->subscribe($projectId, $connection, $subscriptionId, $roles, $channels, $queries);
                 }