Contents

module Jackhammer
  # An object meant to be instantiated once but used on each payload received
  # via the #call method
  class MessageReceiver
    attr_reader :handler_class

    def initialize(handler_class)
      @handler_class = handler_class
    end

    def call(message)
      handler = Object.const_get(handler_class)
      if handler.respond_to?(:perform_async)
        handler.perform_async message
      else
        handler.call message
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
jackhammer-1.3.3	lib/jackhammer/message_receiver.rb
jackhammer-1.3.2	lib/jackhammer/message_receiver.rb
jackhammer-1.3.1	lib/jackhammer/message_receiver.rb
jackhammer-1.3.0	lib/jackhammer/message_receiver.rb
jackhammer-1.2.0	lib/jackhammer/message_receiver.rb
jackhammer-1.1.0	lib/jackhammer/message_receiver.rb
jackhammer-1.0.0	lib/jackhammer/message_receiver.rb