Contents

module Sidekiq
  module Squelch
    class Middleware
      def initialize(notifier)
        @notifier = notifier
      end

      def call(worker, msg, queue)
        yield
      rescue => ex
        @handler ||= ErrorHandler.new
        @handler.notifier = @notifier

        @handler.call ex, {}

        raise
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-squelch-0.1.0	lib/sidekiq/squelch/middleware.rb