# 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
# File lib/activemessaging/threaded_poller.rb, line 221 def inspect "#<Worker #{to_s}>" end
Generated with the Darkfish Rdoc Generator 2.