Class: ActiveJob::Cancel::QueueAdapters::TestAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/active_job/cancel/queue_adapters/test_adapter.rb

Instance Method Summary collapse

Instance Method Details

#cancel(job_id, queue_name) ⇒ Object 



24
25
26
27
28
 
# File 'lib/active_job/cancel/queue_adapters/test_adapter.rb', line 24

def cancel(job_id, queue_name)
  original_count = adapter.enqueued_jobs.count
  adapter.enqueued_jobs = reject_job_from_enqueued_jobs(job_id)
  (original_count == adapter.enqueued_jobs.count) ? false : true
end

#cancel_by(opts, queue_name) ⇒ Object 



30
31
32
33
34
35
 
# File 'lib/active_job/cancel/queue_adapters/test_adapter.rb', line 30

def cancel_by(opts, queue_name)
  unless opts[:provider_job_id]
    raise ArgumentError, 'Please specify ":provider_job_id"'
  end
  self.cancel(opts[:provider_job_id], queue_name)
end