class ActiveMessaging::Worker
Attributes
options[RW]
poller[RW]
Public Class Methods
new(poller, options)
click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 203 def initialize(poller, options) self.poller = poller self.options = options end
Public Instance Methods
execute(message)
click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 208 def execute(message) begin ::ActiveMessaging::Gateway.dispatch(message) rescue Object => err logger.error("ActiveMessaging::Worker.execute error - #{err.inspect}") abort(err) ensure ::ActiveRecord::Base.clear_active_connections! if defined?(::ActiveRecord) end poller.executed!(current_actor) end
inspect()
click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 221 def inspect "#<Worker #{to_s}>" end
logger()
click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 229 def logger; ::ActiveMessaging.logger; end
to_s()
click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 225 def to_s @str ||= "#{Process.pid}-#{Thread.current.object_id}:#{self.object_id}" end