Merge pull request #50 from bzwei/parse_error

Catch decoding parsing error

lib/manageiq/messaging/common.rb

@@ -26,6 +26,10 @@ def decode_body(headers, raw_body)
         else
           raw_body
         end
+      rescue => e # JSON or YAML parsing error
+        logger.error("Error decoding message body: #{e.message}")
+        logger.error(e.backtrace.join("\n"))
+        raw_body
       end
 
       def payload_log(payload)

lib/manageiq/messaging/kafka/queue.rb

@@ -36,6 +36,7 @@ def subscribe_messages_impl(options)
             rescue StandardError => e
               logger.error("Event processing error: #{e.message}")
               logger.error(e.backtrace.join("\n"))
+              raise
             end
             logger.info("Batch message processed")
           end

lib/manageiq/messaging/stomp/queue.rb

@@ -52,6 +52,7 @@ def subscribe_messages_impl(options)
             rescue => e
               logger.error("Message processing error: #{e.message}")
               logger.error(e.backtrace.join("\n"))
+              raise
             end
           end
         end

lib/manageiq/messaging/stomp/topic.rb

@@ -30,6 +30,7 @@ def subscribe_topic_impl(options)
             rescue => e
               logger.error("Event processing error: #{e.message}")
               logger.error(e.backtrace.join("\n"))
+              raise
             end
           end
         end