diff --git a/indexer/services/socks/src/websocket/index.ts b/indexer/services/socks/src/websocket/index.ts
index 795f6a7527..1906d3a72e 100644
--- a/indexer/services/socks/src/websocket/index.ts
+++ b/indexer/services/socks/src/websocket/index.ts
@@ -243,8 +243,6 @@ export class Index {
       return;
     }
 
-    this.connections[connectionId].messageId += 1;
-
     const messageStr = message.toString();
 
     let parsed: IncomingMessage;
@@ -282,6 +280,8 @@ export class Index {
           messageContents: safeJsonStringify(message),
         });
 
+        this.connections[connectionId].messageId += 1;
+
         // Do not wait for this.
         this.subscriptions.subscribe(
           this.connections[connectionId].ws,
@@ -311,6 +311,8 @@ export class Index {
           unsubscribeMessage.id,
         );
 
+        this.connections[connectionId].messageId += 1;
+
         sendMessage(
           this.connections[connectionId].ws,
           connectionId,