Contents

module Messaging
  class ResqueWorker
    @queue = :messaging

    def self.perform(raw_message, handler_name)
      message = Messaging::Message::FromJson.(raw_message)
      handler = handler_name.constantize
      handler.call message
    end
  end
end

Version data entries

34 entries across 34 versions & 1 rubygems

Version	Path
messaging-4.0.12	lib/messaging/resque_worker.rb
messaging-4.0.11	lib/messaging/resque_worker.rb
messaging-4.0.10	lib/messaging/resque_worker.rb
messaging-4.0.10.pre	lib/messaging/resque_worker.rb
messaging-4.0.9	lib/messaging/resque_worker.rb
messaging-4.0.8	lib/messaging/resque_worker.rb
messaging-4.0.7	lib/messaging/resque_worker.rb
messaging-4.0.6	lib/messaging/resque_worker.rb
messaging-4.0.5	lib/messaging/resque_worker.rb
messaging-4.0.4.pre	lib/messaging/resque_worker.rb
messaging-4.0.3.pre	lib/messaging/resque_worker.rb
messaging-4.0.2.pre	lib/messaging/resque_worker.rb
messaging-4.0.1.pre	lib/messaging/resque_worker.rb
messaging-4.0.0.pre	lib/messaging/resque_worker.rb
messaging-3.8.2	lib/messaging/resque_worker.rb
messaging-3.8.1	lib/messaging/resque_worker.rb
messaging-3.8.0	lib/messaging/resque_worker.rb
messaging-3.7.3	lib/messaging/resque_worker.rb
messaging-3.7.2	lib/messaging/resque_worker.rb
messaging-3.7.1	lib/messaging/resque_worker.rb