1 files changed, 19 insertions, 0 deletions
diff --git a/src/util/util/RabbitMQ.ts b/src/util/util/RabbitMQ.ts
new file mode 100644
index 00000000..0f5eb6aa
--- /dev/null
+++ b/src/util/util/RabbitMQ.ts
@@ -0,0 +1,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`);
+ },
+};
|
