feat: print unknown messages when debug is enabled

owen2345 · Jan 16, 2023 · f52bfa8 · f52bfa8
1 parent 1fbc0b4
commit f52bfa8
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/pub_sub_model_sync/service_google.rb b/lib/pub_sub_model_sync/service_google.rb
@@ -109,7 +109,11 @@ def subscribe_to_topics
 
     def process_message(received_message)
       message = received_message.message
-      super(message.data) if message.attributes[SERVICE_KEY]
+      if message.attributes[SERVICE_KEY]
+        super(message.data)
+      elsif config.debug
+        log("Unknown message (#{SERVICE_KEY}): #{[message, message.attributes]}")
+      end
       received_message.acknowledge!
     end
   end