ManageIQ/manageiq-providers-ovirt

View on GitHub
app/models/manageiq/providers/ovirt/infra_manager/event_catcher/runner.rb

Summary

Maintainability
A
0 mins
Test Coverage
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)
end
end