Contents

module Sidetiq
  class Middleware
    def initialize
      @clock = Sidetiq::Clock.instance
    end

    def call(*args)
      # Restart the clock if the thread died.
      @clock.start! if !@clock.ticking?
      yield
    end
  end
end

Sidekiq.configure_server do |config|
  config.server_middleware do |chain|
    chain.add Sidetiq::Middleware
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidetiq-0.1.5	lib/sidetiq/middleware.rb
sidetiq-0.1.4	lib/sidetiq/middleware.rb
sidetiq-0.1.3	lib/sidetiq/middleware.rb
sidetiq-0.1.2	lib/sidetiq/middleware.rb