From 2a97f90a93887ebc26bf8fd9aed7ef16204744d7 Mon Sep 17 00:00:00 2001
From: Charles Packer <packercharles@gmail.com>
Date: Tue, 10 Mar 2026 17:02:44 -0700
Subject: [PATCH] fix(listen): recover queue pump on non-user errors (#1340)

---
 src/websocket/listen-client.ts | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/websocket/listen-client.ts b/src/websocket/listen-client.ts
index b2d5f7e..2ac276a 100644
--- a/src/websocket/listen-client.ts
+++ b/src/websocket/listen-client.ts
@@ -623,6 +623,7 @@ function createRuntime(): ListenerRuntime {
       },
       onDropped: (item, reason, queueLen) => {
         runtime.pendingTurns = queueLen;
+        runtime.queuedMessagesByItemId.delete(item.id);
         if (runtime.socket?.readyState === WebSocket.OPEN) {
           emitToWS(runtime.socket, {
             type: "queue_item_dropped",
@@ -2816,6 +2817,7 @@ async function connectWithRetry(
             console.error("[Listen] Error handling queued message:", error);
           }
           opts.onStatusChange?.("idle", opts.connectionId);
+          scheduleQueuePump(runtime, socket, opts);
         });
     }
   });