Method: Que::Adapters::ActiveRecord#wake_worker_after_commit

Defined in:
lib/que/adapters/active_record.rb

#wake_worker_after_commitObject



10
11
12
13
14
15
16
17
# File 'lib/que/adapters/active_record.rb', line 10

def wake_worker_after_commit
  # Works with ActiveRecord 3.2 and 4 (possibly earlier, didn't check)
  if in_transaction?
    checkout_activerecord_adapter { |adapter| adapter.add_transaction_record(TransactionCallback.new) }
  else
    Que.wake!
  end
end