Merge pull request #20440 from agrare/catch_exceptions_publishing_eve…

…nts_to_kafka Don't allow kafka exceptions to cause EmsEvent.add_queue to fail (cherry picked from commit eb7d827)
ManageIQ · Aug 17, 2020 · f30e55d · f30e55d
1 parent 14508c7
commit f30e55d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/app/models/ems_event.rb b/app/models/ems_event.rb
@@ -264,6 +264,9 @@ def self.publish_event(ems_id, event)
       :event   => event[:event_type],
       :payload => event
     )
+  rescue => err
+    _log.warn("Failed to publish event [#{ems_id}] [#{event[:event_type]}]: #{err}")
+    _log.log_backtrace(err)
   end
 
   private_class_method :publish_event