dandri/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2026-05-25 14:15:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try/catch in GetSafeChannel to maybe catch createchannel errors????

Browse Source
This commit is contained in:
Rory&
2025-12-16 05:15:50 +01:00
parent eafe79095e
commit 8142d8cff9
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/util/util/RabbitMQ.ts
+16 -11
View File
@@ -54,19 +54,24 @@ export const RabbitMQ: {
if (this.channel) return this.channel;
this.channel = await this.connection.createChannel();
console.log(`[RabbitMQ] channel created`);
try {
this.channel = await this.connection.createChannel();
console.log(`[RabbitMQ] channel created`);
// log channel errors
this.channel.on("error", (err) => {
console.error("[RabbitMQ] Channel Error:", err);
});
// log channel errors
this.channel.on("error", (err) => {
console.error("[RabbitMQ] Channel Error:", err);
});
this.channel.on("close", () => {
console.log("[RabbitMQ] channel closed");
this.channel = null;
});
this.channel.on("close", () => {
console.log("[RabbitMQ] channel closed");
this.channel = null;
});
return this.channel;
return this.channel;
} catch (e) {
console.error("[RabbitMQ] Failed to create channel:", e);
return Promise.reject(e);
}
},
};