diff --git a/lib/faktory/connection.rb b/lib/faktory/connection.rb index d611ffd..4cfb673 100644 --- a/lib/faktory/connection.rb +++ b/lib/faktory/connection.rb @@ -6,7 +6,7 @@ module Faktory class Connection class << self def create(options = {}) - size = Faktory.worker? ? (Faktory.options[:concurrency] + 2) : 5 + size = Faktory.worker? ? (Faktory.options[:concurrency] + 5) : 20 ConnectionPool.new(timeout: options[:pool_timeout] || 1, size: size) do Faktory::Client.new(**options) end