Update src/amqp-channel.ts

carlhoerberg · baelter · commit f9a381466bfa · 2025-09-09T13:20:14.000+02:00
diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts
@@ -32,7 +32,7 @@ export class AMQPChannel {
       this.logger?.error(`channel ${this.id} closed: ${reason}`)
       // Propagate channel errors to the connection's onerror handler
       if (this.id !== 0) { // Don't propagate for connection channel (id=0)
-        this.connection.onerror(new AMQPError(reason, this.connection))
+        this.connection.onerror(new AMQPError(`Channel ${this.id} closed: ${reason}`, this.connection))
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ export class AMQPChannel {`
`32`	`32`	this.logger?.error(`channel ${this.id} closed: ${reason}`)
`33`	`33`	`// Propagate channel errors to the connection's onerror handler`
`34`	`34`	`if (this.id !== 0) { // Don't propagate for connection channel (id=0)`
`35`		`- this.connection.onerror(new AMQPError(reason, this.connection))`
	`35`	+ this.connection.onerror(new AMQPError(`Channel ${this.id} closed: ${reason}`, this.connection))
`36`	`36`	`}`
`37`	`37`	`}`
`38`	`38`	`}`