From d8eece32de3b509c9171d0769d042fab672439e1 Mon Sep 17 00:00:00 2001 From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com> Date: Wed, 11 Aug 2021 19:29:39 +0200 Subject: :sparkles: rabbitmq --- src/util/RabbitMQ.ts | 14 ++++++++++++++ 1 file changed, 14 insertions(+) create mode 100644 src/util/RabbitMQ.ts (limited to 'src/util/RabbitMQ.ts') diff --git a/src/util/RabbitMQ.ts b/src/util/RabbitMQ.ts new file mode 100644 index 00000000..9df95231 --- /dev/null +++ b/src/util/RabbitMQ.ts @@ -0,0 +1,14 @@ +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 }; -- cgit 1.5.1