Module: ActiveJob::EnqueueAfterTransactionCommit

Do not use. This module is for internal use only.

Relationships & Source Files
Defined in:	activejob/lib/active_job/enqueue_after_transaction_commit.rb

Instance Method Summary

#raw_enqueue private

Instance Method Details

#raw_enqueue (private)

[ GitHub ]

# File 'activejob/lib/active_job/enqueue_after_transaction_commit.rb', line 6


def raw_enqueue
  after_transaction = case self.class.enqueue_after_transaction_commit
  when :always
    true
  when :never
    false
  else # :default
    queue_adapter.enqueue_after_transaction_commit?
  end

  if after_transaction
    self.successfully_enqueued = true
    ActiveRecord.after_all_transactions_commit do
      self.successfully_enqueued = false
      super
    end
    self
  else
    super
  end
end