Method: ActiveMessaging::Worker#execute

Defined in:
lib/activemessaging/threaded_poller.rb

#execute(message) ⇒ Object 



208
209
210
211
212
213
214
215
216
217
218
219
 
# 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