Contents

# frozen_string_literal: true

require "lamian"

require "rabbit"
require "rabbit/receiving"
require "rabbit/receiving/message"
require "rabbit/receiving/handler_resolver"
require "rabbit/receiving/malformed_message"

class Rabbit::Receiving::Job < ActiveJob::Base
  def perform(message, arguments)
    Lamian.run do
      message = Rabbit::Receiving::Message.build(message, arguments)
      handler = Rabbit::Receiving::HandlerResolver.handler_for(message)
      handler.new(message).call
    rescue Rabbit::Receiving::MalformedMessage => error
      raise if Rabbit.config.environment == :test
      Rabbit.config.exception_notifier.call(error)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rabbit_messaging-0.8.1	lib/rabbit/receiving/job.rb