Sha256: 7268b76c7e1cd56a6055bb15ab9510caf7779f0bd4d9211a508c5d1cf1ba7192
Contents?: true
Size: 291 Bytes
Versions: 14
Compression:
Stored size: 291 Bytes
Contents
module Delayed
module Plugins
class Connection < Plugin
callbacks do |lifecycle|
lifecycle.around(:thread) do |worker, job, &block|
Job.connection_pool.with_connection do
block.call(worker, job)
end
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems