diff options
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/util/RabbitMQ.ts | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/src/util/util/RabbitMQ.ts b/src/util/util/RabbitMQ.ts index 1bfb3f5c..f59f6fe3 100644 --- a/src/util/util/RabbitMQ.ts +++ b/src/util/util/RabbitMQ.ts @@ -1,5 +1,5 @@ import amqp, { Connection, Channel } from "amqplib"; -// import Config from "./Config"; +import { Config } from "./Config"; export const RabbitMQ: { connection: Connection | null; @@ -9,15 +9,14 @@ export const RabbitMQ: { 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`); + 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`); }, }; |