fix: Data not recieving in webhook (#522)

implerhq · Mar 7, 2024 · ff88c99 · ff88c99
2 parents 57f5ca3 + c7f0981
commit ff88c99
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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');
     }