From ca432f99b918a9ad0f3bb2c07c6fa98a3cb062e4 Mon Sep 17 00:00:00 2001
From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com>
Date: Thu, 12 Aug 2021 16:45:23 +0200
Subject: fix rabbitmq export

---
 src/util/RabbitMQ.ts | 26 +++++++++++++++-----------
 1 file changed, 15 insertions(+), 11 deletions(-)

diff --git a/src/util/RabbitMQ.ts b/src/util/RabbitMQ.ts
index 9df95231..9da41990 100644
--- a/src/util/RabbitMQ.ts
+++ b/src/util/RabbitMQ.ts
@@ -1,14 +1,18 @@
 import amqp, { Connection, Channel } from "amqplib";
 import Config from "./Config";
 
-var rabbitCon: Connection;
-var rabbitCh: Channel;
-
-export async function init() {
-	const host = Config.get().rabbitmq.host;
-	if (!host) return;
-	rabbitCon = await amqp.connect(host);
-	rabbitCh = await rabbitCon.createChannel();
-}
-
-export { rabbitCon, rabbitCh };
+export const RabbitMQ: { connection: Connection | null; channel: Channel | null; init: () => Promise<void> } = {
+	connection: null,
+	channel: null,
+	init: async function () {
+		const host = Config.get().rabbitmq.host;
+		if (!host) return;
+		console.log(`[RabbitMQ] connect: ${host}`);
+		this.connection = await amqp.connect(host, {
+			timeout: 1000 * 60,
+		});
+		console.log(`[RabbitMQ] connected`);
+		this.channel = await this.connection.createChannel();
+		console.log(`[RabbitMQ] channel created`);
+	},
+};
-- 
cgit 1.4.1