fixes for workflows #1

Sidd-77 · Dec 23, 2024 · a25f854 · a25f854
1 parent f098c13
commit a25f854
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/apps/db-service/src/lib/messageQueue.ts b/apps/db-service/src/lib/messageQueue.ts
@@ -14,7 +14,7 @@ export class MessageQueue {
       this.connection = await amqp.connect(this.RABBITMQ_URL);
 
       // Handle connection errors and closure
-      this.connection.on("error", (err) => {
+      this.connection.on("error", (err:any) => {
         console.error("RabbitMQ connection error:", err);
         this.handleConnectionError();
       });

diff --git a/apps/notification-service/package.json b/apps/notification-service/package.json
@@ -13,6 +13,7 @@
     "@types/mongoose": "^5.11.96",
     "@types/web-push": "^3.6.4",
     "cors": "^2.8.5",
+    "amqplib": "^0.10.5",
     "dotenv": "^16.4.7",
     "express": "^4.21.2",
     "mongoose": "^8.9.2",

diff --git a/apps/notification-service/src/notificationQueue.ts b/apps/notification-service/src/notificationQueue.ts
@@ -14,7 +14,7 @@ export class NotificationQueue {
       this.connection = await amqp.connect(this.RABBITMQ_URL);
 
       // Handle connection errors and closure
-      this.connection.on("error", (err) => {
+      this.connection.on("error", (err:any) => {
         console.error("RabbitMQ connection error:", err);
         this.handleConnectionError();
       });
@@ -89,7 +89,7 @@ export class NotificationQueue {
           noAck: false, // Enable manual acknowledgment
         },
       );
-    } catch (error) {
+    } catch (error:any) {
       console.error("Error setting up message consumer:", error);
       // Attempt to reconnect
       this.handleConnectionError();
@@ -102,7 +102,7 @@ export class NotificationQueue {
       await this.connection?.close();
       this.isInitialized = false;
       console.log("RabbitMQ connections closed");
-    } catch (error) {
+    } catch (error:any) {
       console.error("Error closing RabbitMQ connections:", error);
     }
   }