Contents

# frozen_string_literal: true

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)
      Log.info { 'message received for ' + handler_class.to_s }
      Log.debug { message.to_s }
      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

1 entries across 1 versions & 1 rubygems

Version	Path
jackhammer-0.2.1	lib/jackhammer/message_receiver.rb