fixup! fix: propagate channel errors to connection and handle channel close properly

carlhoerberg · baelter · commit 990c46c5846c · 2025-09-09T13:20:14.000+02:00
diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts
@@ -766,6 +766,7 @@ export class AMQPChannel {
    * @param [err] - why the channel was closed
    */
   setClosed(err?: Error): void {
+    const closedByServer = err !== undefined
     err ||= new Error("Connection closed by client")
     if (!this.closed) {
       this.closed = true
@@ -776,10 +777,7 @@ export class AMQPChannel {
       this.unconfirmedPublishes.forEach(([, , reject]) => reject(err))
       this.unconfirmedPublishes.length = 0
       
-      // Call onerror for any error, whether from server or from a channel operation
-      if (err.message !== "Connection closed by client") {
-        this.onerror(err.message)
-      }
+      if (closedByServer) this.onerror(err.message)
     }
   }
 
