fixing TypeError: callback is not a function

airqo-platform · Feb 26, 2025 · 29aba80 · 29aba80
1 parent 9ad988f
commit 29aba80
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/auth-service/utils/token.util.js b/src/auth-service/utils/token.util.js
@@ -80,14 +80,16 @@ let blacklistQueue = async.queue(async (task, callback) => {
       .then(() => {
         logObject(`🤩🤩 Published IP ${ip} to the "ip-address" topic.`);
         // logger.info(`🤩🤩 Published IP ${ip} to the "ip-address" topic.`);
-        callback();
+        // callback();
       });
     await kafkaProducer.disconnect();
+    callback();
   } catch (error) {
     logObject("error", error);
     // logger.error(
     //   `🐛🐛 KAFKA Producer Internal Server Error --- IP_ADDRESS: ${ip} --- ${error.message}`
     // );
+    callback();
   }
 }, 1); // Limit the number of concurrent tasks to 1