Contents

module Shoryuken
  module Middleware
    module Server
      class Timing
        include Util

        def call(_worker, queue, _sqs_msg, _body)
          started_at = Time.now

          logger.info { "started at #{started_at}" }

          yield

          total_time = elapsed(started_at)

          if (total_time / 1000.0) > (timeout = Shoryuken::Client.queues(queue).visibility_timeout)
            logger.warn { "exceeded the queue visibility timeout by #{total_time - (timeout * 1000)} ms" }
          end

          logger.info { "completed in: #{total_time} ms" }
        rescue
          logger.info { "failed in: #{elapsed(started_at)} ms" }
          raise
        end
      end
    end
  end
end

Version data entries

27 entries across 27 versions & 1 rubygems

Version	Path
shoryuken-6.2.1	lib/shoryuken/middleware/server/timing.rb
shoryuken-6.2.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-6.1.1	lib/shoryuken/middleware/server/timing.rb
shoryuken-6.1.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-6.0.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.3.2	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.3.1	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.3.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.2.3	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.2.2	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.2.1	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.2.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.1.1	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.1.0	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.6	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.5	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.4	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.3	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.2	lib/shoryuken/middleware/server/timing.rb
shoryuken-5.0.1	lib/shoryuken/middleware/server/timing.rb