Class: Sidekiq::Monitor::Client::Middleware

Inherits:

Object

Object
Sidekiq::Monitor::Client::Middleware

Defined in:: lib/sidekiq/monitor/client/middleware.rb

Instance Method Summary collapse

#call(worker_class, item, queue, redis_pool = nil) ⇒ Object
#initialize(options = nil) ⇒ Middleware constructor

A new instance of Middleware.

Constructor Details

#initialize(options = nil) ⇒ `Middleware`

Returns a new instance of Middleware.



5
6
7

# File 'lib/sidekiq/monitor/client/middleware.rb', line 5

def initialize(options=nil)
  @processor = Monitor::Processor.new
end

Instance Method Details

#call(worker_class, item, queue, redis_pool = nil) ⇒ `Object`

# File 'lib/sidekiq/monitor/client/middleware.rb', line 9

def call(worker_class, item, queue, redis_pool=nil)
  ActiveRecord::Base.connection_pool.with_connection do
    @processor.queue(worker_class, item, queue)
    yield
  end
end