module SidekiqScheduler::Client

def remove_delayed_from_queue(queue, timestamp, klass, *args)

Returns the number of jobs removed

Sidekiq::Client.remove_delayed('foo', Time.now + 600, MyWorker, 'foo', 1, :bat => 'bar')
Example usage:

def remove_delayed_from_queue(queue, timestamp, klass, *args)
  timestamp = timestamp.to_i
  item = {'class' => klass.to_s, 'args' => args}
  item['queue'] = queue.to_s if queue
  search = MultiJson.encode(item)
  count = Sidekiq.redis { |r| r.lrem("delayed:#{timestamp}", 0, search) }
  remove_scheduler_queue(timestamp)
  count
end

Instance Methods