fix: reconection

Vitruveo · Mar 8, 2024 · 296a521 · 296a521
1 parent 57bc088
commit 296a521
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 5 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "vtru-studio-websocket",
-    "version": "1.1.17",
+    "version": "1.1.18",
     "description": "",
     "main": "index.js",
     "scripts": {

diff --git a/src/controllers/index.ts b/src/controllers/index.ts
@@ -8,13 +8,13 @@ const logger = debug('controllers');
 export const controllersStart = async () => {
     const rabbitmqStatus = await getConnection();
     if (!rabbitmqStatus.isConnected || !rabbitmqStatus.connection) {
-        logger('RabbitMQ connection failed, retrying in 10 seconds...');
+        console.log('RabbitMQ connection failed, retrying in 10 seconds...');
         setTimeout(controllersStart, 10000);
         return;
     }
 
     rabbitmqStatus.connection.on('close', () => {
-        logger('RabbitMQ connection closed, restarting in 10 seconds...');
+        console.log('RabbitMQ connection closed, restarting in 10 seconds...');
         setTimeout(controllersStart, 10000);
     });
 

diff --git a/src/services/rabbitmq/index.ts b/src/services/rabbitmq/index.ts
@@ -25,6 +25,16 @@ export const getConnection = async () => {
     try {
         if (!status.connection) {
             status.connection = await rabbitmq.connect(RABBITMQ_URL);
+            status.connection.on('close', () => {
+                status.isConnected = false;
+                status.connection = null;
+                console.error('RabbitMQ connection closed');
+            });
+            status.connection.on('error', (error) => {
+                status.isConnected = false;
+                status.connection = null;
+                console.error('Error occurred in RabbitMQ connection:', error);
+            });
             status.isConnected = true;
         }
     } catch (err) {