aboutsummaryrefslogblamecommitdiffstats
path: root/activejob/lib/active_job/execution.rb
blob: 7c4151fc90260ecadcd19eda0b712ec714072af1 (plain) (tree)
1
2
3
4
5
6
7
8
9
                                  
                              

                
                  
                                 
                                    
 
                                                                   







                                             
 
                                    



                                                       

         
 
                                                                               
                                                                                    



                                     
                               
                           
         
                       
                                                        


                  
                              


       
require 'active_support/rescuable'
require 'active_job/arguments'

module ActiveJob
  module Execution
    extend ActiveSupport::Concern
    include ActiveSupport::Rescuable

    # Includes methods for executing and performing jobs instantly.
    module ClassMethods
      # Performs the job immediately.
      #
      #   MyJob.perform_now("mike")
      #
      def perform_now(*args)
        job_or_instantiate(*args).perform_now
      end

      def execute(job_data) #:nodoc:
        ActiveJob::Callbacks.run_callbacks(:execute) do
          job = deserialize(job_data)
          job.perform_now
        end
      end
    end

    # Performs the job immediately. The job is not sent to the queueing adapter
    # but directly executed by blocking the execution of others until it's finished.
    #
    #   MyJob.new(*args).perform_now
    def perform_now
      deserialize_arguments_if_needed
      run_callbacks :perform do
        perform(*arguments)
      end
    rescue => exception
      rescue_with_handler(exception) || raise(exception)
    end

    def perform(*)
      fail NotImplementedError
    end
  end
end