🥅 soft queue purging

karafra · Jul 18, 2022 · 1c6f09a · 1c6f09a
1 parent bec6544
commit 1c6f09a
Showing 1 changed file with 6 additions and 3 deletions.
diff --git 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> {