Sha256: 548a61d5dd46e2a760c3fd47a418583bccfddef48fc8f1b77c9500e7649be3b4
Contents?: true
Size: 364 Bytes
Versions: 38
Compression:
Stored size: 364 Bytes
Contents
require 'timeout'
module Sidekiq
module Middleware
module Server
class Timeout
def call(worker, msg, queue)
if msg['timeout'] && msg['timeout'].to_i != 0
::Timeout.timeout(msg['timeout'].to_i) do
yield
end
else
yield
end
end
end
end
end
end
Version data entries
38 entries across 38 versions & 2 rubygems