feat(whtsapp): implementado rotina de envio de mensagem com rabbitmq.

ldurans · Jul 24, 2022 · 7b79ee2 · 7b79ee2
1 parent 144abce
commit 7b79ee2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/backend/src/app.ts b/backend/src/app.ts
@@ -71,7 +71,7 @@ if (process.env.AMQP_URL) {
   (async () => {
     const rabbitWhatsapp = new RabbitmqServer(process.env.AMQP_URL || "");
     await rabbitWhatsapp.start();
-    logger.info("Rabbit started", process.env.AMQP_URL);
+    logger.info("Rabbit started Whatsapp", process.env.AMQP_URL);
     global.rabbitWhatsapp = rabbitWhatsapp;
   })();
   Consumer360();

diff --git a/backend/src/libs/rabbitmq-server.ts b/backend/src/libs/rabbitmq-server.ts
@@ -46,6 +46,7 @@ export default class RabbitmqServer {
     callback: (message: Message) => Promise<void>
   ) {
     this.channel.prefetch(1, false);
+    await this.channel.assertQueue(queue, { durable: true });
     this.channel.consume(queue, async (message: any) => {
       try {
         await callback(message);