diff --git a/apps/server/src/modules/tldraw/service/tldraw.ws.service.ts b/apps/server/src/modules/tldraw/service/tldraw.ws.service.ts
index 29898395b3a..49cd107f665 100644
--- a/apps/server/src/modules/tldraw/service/tldraw.ws.service.ts
+++ b/apps/server/src/modules/tldraw/service/tldraw.ws.service.ts
@@ -175,7 +175,7 @@ export class TldrawWsService {
 			void this.messageHandler(ws, doc, new Uint8Array(message));
 		});
 
-		const redisUpdates = await getDocUpdatesFromQueue(this.sub, doc);
+		const redisUpdates = await getDocUpdatesFromQueue(this.pub, doc);
 		const redisYDoc = new Doc();
 		redisYDoc.transact(() => {
 			for (const u of redisUpdates) {