Explorar o código

impl error handling when publishing

Yuki Takei %!s(int64=5) %!d(string=hai) anos
pai
achega
e9006253fa
Modificáronse 1 ficheiros con 8 adicións e 2 borrados
  1. 8 2
      src/server/service/config-manager.js

+ 8 - 2
src/server/service/config-manager.js

@@ -312,7 +312,13 @@ class ConfigManager {
 
   async publishUpdateMessage(updatedAt) {
     const message = JSON.stringify({ updatedAt });
-    return this.configPubsub.publish(message);
+
+    try {
+      await this.configPubsub.publish(message);
+    }
+    catch (e) {
+      logger.error('Failed to publish update message with configPubsub: ', e.message);
+    }
   }
 
   async handleUpdateMessage(message) {
@@ -324,7 +330,7 @@ class ConfigManager {
       parsedMessage = JSON.parse(message);
 
       if (!(parsedMessage instanceof Object)) {
-        throw new Error('A message could not be parsed to JSON object', message);
+        throw new Error('A message could not be parsed to JSON object: ', message);
       }
 
       // parse Date