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`);
- },
-};
|
