Class: Determinator::Tracking::Sidekiq::Middleware

Inherits:

Object

• Object
• Determinator::Tracking::Sidekiq::Middleware

Defined in:

lib/determinator/tracking/sidekiq/middleware.rb

Instance Method Summary

• #call(worker, job, queue) { ... } ⇒ Void

Instance Method Details

#call(worker, job, queue) { ... } ⇒ Void

Parameters:

• worker (Object) —

  the worker instance

• job (Hash) —

  the full job payload

  • @see github.com/mperham/sidekiq/wiki/Job-Format

• queue (String) —

  the name of the queue the job was pulled from

Yields:

• the next middleware in the chain or worker ‘perform` method

Returns:

• (Void)

# File 'lib/determinator/tracking/sidekiq/middleware.rb', line 13

def call(worker, job, queue)
  begin
    Determinator::Tracking.start!(:sidekiq)
    yield
  rescue => ex
    error = true
    raise
  ensure
    Determinator::Tracking.finish!(
      endpoint: Determinator::Tracking.collect_endpoint_info(worker.class.name),
      queue: queue,
      error: !!error
    )
  end
end