feat: print received unknown messages when debug is enabled

Author: owen2345

lib/pub_sub_model_sync/service_kafka.rb

@@ -72,7 +72,11 @@ def producer
     end
 
     def process_message(message)
-      super(message.value) if message.headers[SERVICE_KEY]
+      if message.headers[SERVICE_KEY]
+        super(message.value)
+      elsif config.debug
+        log("Unknown message (#{SERVICE_KEY}): #{[message, message.headers]}")
+      end
       consumer.mark_message_as_processed(message)
     end
 

lib/pub_sub_model_sync/service_rabbit.rb

@@ -65,7 +65,11 @@ def message_settings(payload)
     end
 
     def process_message(queue, delivery_info, meta_info, payload)
-      super(payload) if meta_info[:type] == SERVICE_KEY
+      if meta_info[:type] == SERVICE_KEY
+        super(payload)
+      elsif config.debug
+        log("Unknown message (#{SERVICE_KEY}): #{[payload, meta_info]}")
+      end
       queue.channel.ack(delivery_info.delivery_tag)
     end