Sha256: 598ce63d6ddf16db8c5117ec5358a3bb4832d39324df1be164df7833925540ba
Contents?: true
Size: 1.93 KB
Versions: 21
Compression:
Stored size: 1.93 KB
Contents
module Actions
module Katello
module EventQueue
class PollerThread
SLEEP_INTERVAL = 2
COUNT_UPDATE_INTERVAL = 250
cattr_accessor :instance
def self.initialize(logger)
self.instance ||= self.new(logger)
end
def self.close
self.instance.close if self.instance
self.instance = nil
end
def initialize(logger)
@logger = logger
end
def close
@thread.kill if @thread
end
def run_event(event)
@logger.debug("event_queue_event: #{event.event_type}, #{event.object_id}")
::User.as_anonymous_admin do
::Katello::EventQueue.event_class(event.event_type).new(event.object_id).run
end
rescue => e
@logger.error("event_queue_error: #{event.event_type}, #{event.object_id}")
@logger.error(e.message)
@logger.error(e.backtrace.join("\n"))
ensure
::Katello::EventQueue.clear_events(event.event_type, event.object_id, event.created_at)
end
def poll_for_events(suspended_action)
@thread.kill if @thread
@thread = Thread.new do
loop do
Rails.application.executor.wrap do
begin
count = 0
until (event = ::Katello::EventQueue.next_event).nil?
run_event(event)
count += 1
if count > COUNT_UPDATE_INTERVAL
suspended_action.notify_count(count)
count = 0
end
end
suspended_action.notify_count(count) if count > 0
sleep SLEEP_INTERVAL
rescue => e
suspended_action.notify_fatal(e)
raise e
end
end
end
end
end
end
end
end
end
Version data entries
21 entries across 21 versions & 1 rubygems