Don't allow kafka exceptions to cause EmsEvent.add_queue to fail

If there are issues publishing events to kafka we shouldn't allow them to cause the main MiqQueue EmsEvent.add to fail
agrare · Aug 13, 2020 · aab6b9c · aab6b9c
1 parent 5f2a3a7
commit aab6b9c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/app/models/ems_event.rb b/app/models/ems_event.rb
@@ -274,6 +274,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