Log rabbitmq channel allocations 2

spacebarchat · Nov 2, 2024 · e018b3a · e018b3a
1 parent b276981
commit e018b3a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/gateway/listener/listener.ts b/src/gateway/listener/listener.ts
@@ -82,7 +82,7 @@ export async function setupListener(this: WebSocket) {
 
 	const opts: {
 		acknowledge: boolean;
-		channel?: AMQChannel & { queues?: unknown };
+		channel?: AMQChannel & { queues?: unknown, ch?: number };
 	} = {
 		acknowledge: true,
 	};
@@ -91,10 +91,10 @@ export async function setupListener(this: WebSocket) {
 
 	console.log("[RabbitMQ] setupListener: open for ", this.user_id);
 	if (RabbitMQ.connection) {
-		console.log("[RabbitMQ] setupListener: opts.channel = ", typeof opts.channel, opts.channel);
+		console.log("[RabbitMQ] setupListener: opts.channel = ", typeof opts.channel, "with channel id", opts.channel?.ch);
 		opts.channel = await RabbitMQ.connection.createChannel();
 		opts.channel.queues = {};
-		console.log("[RabbitMQ] channel created: ", typeof opts.channel, opts.channel);
+		console.log("[RabbitMQ] channel created: ", typeof opts.channel, "with channel id", opts.channel?.ch);
 	}
 
 	this.events[this.user_id] = await listenEvent(this.user_id, consumer, opts);
@@ -132,7 +132,7 @@ export async function setupListener(this: WebSocket) {
 	});
 
 	this.once("close", () => {
-		console.log("[RabbitMQ] setupListener: close for ", this.user_id, "=", typeof opts.channel, opts.channel);
+		console.log("[RabbitMQ] setupListener: close for", this.user_id, "=", typeof opts.channel, "with channel id", opts.channel?.ch);
 		if (opts.channel) opts.channel.close();
 		else {
 			Object.values(this.events).forEach((x) => x?.());