ManageIQ/manageiq

class MiqEventHandler::Runner < MiqQueueWorkerBase::Runner
  def process_miq_messaging_message(msg)
    EmsEvent.add(msg.sender, msg.payload.deep_symbolize_keys)
  end
end