From a92c6637cea0ce595c712c3d445b57a1184e833e Mon Sep 17 00:00:00 2001 From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com> Date: Thu, 12 Aug 2021 20:33:42 +0200 Subject: :sparkles: rtc --- rtc/src/util/RabbitMQ.ts | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) create mode 100644 rtc/src/util/RabbitMQ.ts (limited to 'rtc/src/util/RabbitMQ.ts') diff --git a/rtc/src/util/RabbitMQ.ts b/rtc/src/util/RabbitMQ.ts new file mode 100644 index 00000000..9da41990 --- /dev/null +++ b/rtc/src/util/RabbitMQ.ts @@ -0,0 +1,18 @@ +import amqp, { Connection, Channel } from "amqplib"; +import Config from "./Config"; + +export const RabbitMQ: { connection: Connection | null; channel: Channel | null; init: () => Promise } = { + 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.5.1