Class: Sidetiq::Middleware

Inherits:

Object

• Object
• Sidetiq::Middleware

Defined in:

lib/sidetiq/middleware.rb

Instance Method Summary

• #call(*args) ⇒ Object
• #initialize ⇒ Middleware constructor

  A new instance of Middleware.

Constructor Details

#initialize ⇒ Middleware

Returns a new instance of Middleware.

# File 'lib/sidetiq/middleware.rb', line 3

def initialize
  @clock = Sidetiq::Clock.instance
end

Instance Method Details

#call(*args) ⇒ Object

# File 'lib/sidetiq/middleware.rb', line 7

def call(*args)
  # Restart the clock if the thread died.
  if !@clock.ticking?
    Sidetiq.logger.warn "Sidetiq::Clock thread died. Restarting..."
    @clock.start!
  end
  yield
end