15 lines
348 B
TypeScript
15 lines
348 B
TypeScript
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 };
|