summary refs log tree commit diff
path: root/rtc/src/util/RabbitMQ.ts
diff options
context:
space:
mode:
authorFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-08-13 13:03:18 +0200
committerFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-08-13 13:03:18 +0200
commitebff2f42417e0e579d59d296f5150024f8c850ee (patch)
tree707b264d239859853411adb5142b64727debd51b /rtc/src/util/RabbitMQ.ts
parentFix naming (diff)
parentabstract Event emission (diff)
downloadserver-ebff2f42417e0e579d59d296f5150024f8c850ee.tar.xz
Merge branch 'master' into pr/darkhpp/261-2
Diffstat (limited to 'rtc/src/util/RabbitMQ.ts')
-rw-r--r--rtc/src/util/RabbitMQ.ts18
1 files changed, 0 insertions, 18 deletions
diff --git a/rtc/src/util/RabbitMQ.ts b/rtc/src/util/RabbitMQ.ts
deleted file mode 100644
index 9da41990..00000000
--- a/rtc/src/util/RabbitMQ.ts
+++ /dev/null
@@ -1,18 +0,0 @@
-import amqp, { Connection, Channel } from "amqplib";
-import Config from "./Config";
-
-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`);
-	},
-};