app/models/manageiq/providers/ovirt/infra_manager/event_catcher/runner.rb
require 'manageiq/providers/ovirt/legacy/event_monitor' class ManageIQ::Providers::Ovirt::InfraManager::EventCatcher::Runner < ManageIQ::Providers::BaseManager::EventCatcher::Runner def event_monitor_handle @event_monitor_handle ||= ManageIQ::Providers::Ovirt::Legacy::EventMonitor.new(:ems => @ems) end def reset_event_monitor_handle @event_monitor_handle = nil end def stop_event_monitor @event_monitor_handle.stop unless @event_monitor_handle.nil?Avoid rescuing the `Exception` class. Perhaps you meant to rescue `StandardError`? rescue Exception => err _log.warn("#{log_prefix} Event Monitor Stop errored because [#{err.message}]") _log.warn("#{log_prefix} Error details: [#{err.details}]") _log.log_backtrace(err) ensure reset_event_monitor_handle end def monitor_events event_monitor_handle.start event_monitor_running event_monitor_handle.each_batch do |events| @queue.enq events sleep_poll_normal end ensure reset_event_monitor_handle end def queue_event(event) _log.info "#{log_prefix} Caught event [#{event.name}]" parser = @ems.class::EventParser event_hash = parser.event_to_hash(event, @cfg[:ems_id]) EmsEvent.add_queue('add', @cfg[:ems_id], event_hash) end def filtered?(event) @ems.filtered_event_names.include?(event.name) endend