src/util/RabbitMQ.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
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 };