7
8
9
10
11
12
|
# File 'lib/faktory/connection.rb', line 7
def create(options={})
size = Faktory.worker? ? (Faktory.options[:concurrency] + 2) : 5
ConnectionPool.new(:timeout => options[:pool_timeout] || 1, :size => size) do
Faktory::Client.new(options)
end
end
|