Class: SidekiqSchedulable::Middleware::Server

Inherits:

Object

Object
SidekiqSchedulable::Middleware::Server

Defined in:: lib/sidekiq_schedulable/middleware/server.rb

Instance Method Summary collapse

#call(worker, item, queue) ⇒ Object
#initialize(schedules = {}) ⇒ Server constructor

A new instance of Server.

Constructor Details

#initialize(schedules = {}) ⇒ `Server`

Returns a new instance of Server.



6
7
8

# File 'lib/sidekiq_schedulable/middleware/server.rb', line 6

def initialize(schedules = {})
  @schedules = schedules
end

Instance Method Details

#call(worker, item, queue) ⇒ `Object`

# File 'lib/sidekiq_schedulable/middleware/server.rb', line 10

def call(worker, item, queue)
  start_time = Time.now
  yield
ensure
  schedule_next_job(item, start_time) if item['scheduled']
end