Contents

module Sidekiq
  module Monitor
    class Middleware
      def call(worker, message, queue)
        event = Sidekiq::Monitor::Event.create_or_update_with(worker, message, queue)

        begin
          yield
          event.finish
        rescue Exception => e
          event.error(e)
          raise
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-monitor-0.0.2	lib/sidekiq/monitor/middleware.rb