summary refs log tree commit diff
path: root/src/util/RabbitMQ.ts
diff options
context:
space:
mode:
authorFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-08-12 20:33:42 +0200
committerFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2021-08-12 20:33:42 +0200
commita92c6637cea0ce595c712c3d445b57a1184e833e (patch)
treeb4aa50b4091617195025e2ed36406ae61e8fe3b9 /src/util/RabbitMQ.ts
parent:sparkles: util (diff)
downloadserver-a92c6637cea0ce595c712c3d445b57a1184e833e.tar.xz
:sparkles: rtc
Diffstat (limited to 'src/util/RabbitMQ.ts')
-rw-r--r--src/util/RabbitMQ.ts18
1 files changed, 0 insertions, 18 deletions
diff --git a/src/util/RabbitMQ.ts b/src/util/RabbitMQ.ts
deleted file mode 100644

index 9da41990..00000000 --- a/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`); - }, -};