Class: SidekiqUniqueJobs::Middleware::Client::UniqueJobs

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb

Constant Summary collapse

STRATEGIES = 
[
  Strategies::TestingInline,
  Strategies::Unique
]

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#item ⇒ Object (readonly)

Returns the value of attribute item.



13
14
15
 
# File 'lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb', line 13

def item
  @item
end

#redis_pool ⇒ Object (readonly)

Returns the value of attribute redis_pool.



13
14
15
 
# File 'lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb', line 13

def redis_pool
  @redis_pool
end

#worker_class ⇒ Object (readonly)

Returns the value of attribute worker_class.



13
14
15
 
# File 'lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb', line 13

def worker_class
  @worker_class
end

Instance Method Details

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



15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb', line 15

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

  if unique_enabled?
    strategy.review(worker_class, item, queue, redis_pool) { yield }
  else
    yield
  end
end