Module: Sidekiq::TestingDefer

Defined in:
lib/sidekiq/defer/testing.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.enable_delay_testing! ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/sidekiq/defer/testing.rb', line 14

def self.enable_delay_testing!
  Sidekiq::Defer::DelayedMailer.extend(TestingDefer) if defined?(Sidekiq::Defer::DelayedMailer)
  return unless defined?(Sidekiq::Defer::DelayedModel)

  Sidekiq::Defer::DelayedModel.extend(TestingDefer)
end

Instance Method Details

#jobs_for(klass) ⇒ Object 



7
8
9
10
11
12
 
# File 'lib/sidekiq/defer/testing.rb', line 7

def jobs_for(klass)
  jobs.select do |job|
    marshalled = job['args'][0]
    marshalled.index(klass.to_s) && YAML.safe_load(marshalled, permitted_classes: [Symbol])[0] == klass
  end
end