Module: ActiveJob::Cancel

Extended by:
ActiveSupport::Concern
Defined in:
lib/active_job/cancel.rb,
lib/active_job/cancel/version.rb,
lib/active_job/cancel/queue_adapters.rb,
lib/active_job/cancel/queue_adapters/test_adapter.rb,
lib/active_job/cancel/queue_adapters/resque_adapter.rb,
lib/active_job/cancel/queue_adapters/sidekiq_adapter.rb,
lib/active_job/cancel/queue_adapters/delayed_job_adapter.rb

Defined Under Namespace

Modules: ClassMethods, QueueAdapters

Constant Summary collapse

SUPPORTED_ADAPTERS = 
%w(Sidekiq DelayedJob Resque Test).freeze
VERSION = 
"0.3.2"

Instance Method Summary collapse

Instance Method Details

#cancel ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/active_job/cancel.rb', line 13

def cancel
  if self.class.can_cancel?
    self.class.cancel_adapter_class.new.cancel(job_id, queue_name)
  else
    raise NotImplementedError, 'This queueing backend does not support cancel.'
  end
end