util/src/util/RabbitMQ.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

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 () {
		return;
		// 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`);
	},
};