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

Forgot to make rabbitmq static

Browse Source
This commit is contained in:
Rory&
2025-12-16 09:23:39 +01:00
parent 9f9cdadcb1
commit 01fa1a9f2a
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/util/util/RabbitMQ.ts
+4 -4
View File
@@ -20,10 +20,10 @@ import amqp, { Channel, ChannelModel } from "amqplib";
import { Config } from "./Config";
export class RabbitMQ {
public connection: ChannelModel | null = null;
public channel: Channel | null = null;
public static connection: ChannelModel | null = null;
public static channel: Channel | null = null;
async init() {
static async init() {
const host = Config.get().rabbitmq.host;
if (!host) return;
console.log(`[RabbitMQ] connect: ${host}`);
@@ -46,7 +46,7 @@ export class RabbitMQ {
await this.getSafeChannel(); // why is this here?
}
async getSafeChannel(): Promise<Channel> {
static async getSafeChannel(): Promise<Channel> {
if (!this.connection) return Promise.reject();
if (this.channel) return this.channel;