Contents

# frozen_string_literal: true
module Apress
  module Api
    class EventHandlerEnqueueingJob
      include Resque::Integration

      queue :api_callbacks

      def self.perform(handler, event_params)
        job = handler.camelize.constantize

        if job.respond_to?(:enqueue)
          job.enqueue(event_params)
        else
          Resque.enqueue(job, event_params)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
apress-api-1.24.2	app/jobs/apress/api/event_handler_enqueueing_job.rb