From 213c5a4dcb898f7046230b2c22d0c68e3ce280cd Mon Sep 17 00:00:00 2001
From: Mayur <iammaya.kakade@gmail.com>
Date: Thu, 7 Mar 2024 13:30:44 +0530
Subject: [PATCH] fix: Data not recieving in webhook

---
 apps/api/src/app/shared/services/queue.service.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/api/src/app/shared/services/queue.service.ts b/apps/api/src/app/shared/services/queue.service.ts
index 6fd12ea5e..aafec95d6 100644
--- a/apps/api/src/app/shared/services/queue.service.ts
+++ b/apps/api/src/app/shared/services/queue.service.ts
@@ -30,9 +30,9 @@ export class QueueService {
 
   publishToQueue(queueName: QueuesEnum.END_IMPORT, data: EndImportData): void;
   publishToQueue(queueName: QueuesEnum.PROCESS_FILE, data: ProcessFileData): void;
-  publishToQueue(queueName: QueuesEnum, data: PublishToQueueData) {
+  async publishToQueue(queueName: QueuesEnum, data: PublishToQueueData) {
     if (this.connection.isConnected()) {
-      this.chanelWrapper.sendToQueue(queueName, data, { durable: false });
+      await this.chanelWrapper.sendToQueue(queueName, data, { durable: false });
     } else {
       throw new Error('RabbitMQ connection is not established');
     }