class SidekiqSchedulable::Middleware::Client

Public Class Methods

new(schedules = {}) click to toggle source
# File lib/sidekiq_schedulable/middleware/client.rb, line 4
def initialize(schedules = {})
  @schedules = schedules
end

Public Instance Methods

call(worker_class, item, queue, redis_pool) { || ... } click to toggle source
# File lib/sidekiq_schedulable/middleware/client.rb, line 8
def call(worker_class, item, queue, redis_pool)
  if schedule = @schedules[worker_class]
    item['scheduled'] = true
  end
  yield
end