From 1c6f09a19f034aec13c86bfbdd6cea85412baf79 Mon Sep 17 00:00:00 2001
From: karafra <darius.kralovic1@protonmail.com>
Date: Mon, 18 Jul 2022 04:30:51 +0200
Subject: [PATCH] :goal_net: soft queue purging

---
 src/services/amqp/amqp.service.ts | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/services/amqp/amqp.service.ts b/src/services/amqp/amqp.service.ts
index a17bc75..39acdda 100644
--- a/src/services/amqp/amqp.service.ts
+++ b/src/services/amqp/amqp.service.ts
@@ -4,15 +4,18 @@ import { Injectable } from '@nestjs/common';
 @Injectable()
 export class AmqpService {
   private lastDispatch: number = Date.now();
-
   public constructor(
     @InjectAmqpClient() private readonly amqpClient: AmqpClient,
   ) {}
 
   public async purgeQueue(queueName: string): Promise<void> {
     const channel = await this.amqpClient.channel();
-    await channel.queuePurge(queueName);
-    await channel.close('Service stopped', 320);
+    try {
+      await channel.queuePurge(queueName);
+    } catch {
+    } finally {
+      await channel.close('Service stopped', 320);
+    }
   }
 
   public async popFromQueue<T>(queueName: string): Promise<T> {