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

carlhoerberg · baelter · commit b5f55e5f94e3 · 2025-09-09T13:20:14.000+02:00
diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts
@@ -776,7 +776,6 @@ export class AMQPChannel {
       // Reject and clear all unconfirmed publishes
       this.unconfirmedPublishes.forEach(([, , reject]) => reject(err))
       this.unconfirmedPublishes.length = 0
-      
       if (closedByServer) this.onerror(err.message)
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -776,7 +776,6 @@ export class AMQPChannel {`
`776`	`776`	`// Reject and clear all unconfirmed publishes`
`777`	`777`	`this.unconfirmedPublishes.forEach(([, , reject]) => reject(err))`
`778`	`778`	`this.unconfirmedPublishes.length = 0`
`779`		`-`
`780`	`779`	`if (closedByServer) this.onerror(err.message)`
`781`	`780`	`}`
`782`	`781`	`}`