Class: SidekiqUniqueJobs::Client::Middleware

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
OptionsWithFallback
Defined in:
lib/sidekiq_unique_jobs/testing.rb,
lib/sidekiq_unique_jobs/client/middleware.rb

Instance Method Summary collapse

Methods included from OptionsWithFallback

included, #lock, #lock_class, #lock_type, #lock_type_from, #log_duplicate_payload?, #options, #unique_disabled?, #unique_enabled?, #unique_lock

Instance Method Details

#_server ⇒ Object 



23
24
25
 
# File 'lib/sidekiq_unique_jobs/testing.rb', line 23

def _server
  SidekiqUniqueJobs::Server::Middleware.new
end

#call(worker_class, item, queue, redis_pool = nil) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/sidekiq_unique_jobs/testing.rb', line 7

def call(worker_class, item, queue, redis_pool = nil)
  worker_class = SidekiqUniqueJobs.worker_class_constantize(worker_class)

  if Sidekiq::Testing.inline?
    _server.call(worker_class.new, item, queue, redis_pool) do
      call_real(worker_class, item, queue, redis_pool) do
        yield
      end
    end
  else
    call_real(worker_class, item, queue, redis_pool) do
      yield
    end
  end
end

#call_real ⇒ Object 



6
 
# File 'lib/sidekiq_unique_jobs/testing.rb', line 6

alias call_real call