diff --git a/lib/perfectqueue/backend/rdb.rb b/lib/perfectqueue/backend/rdb.rb index 33502af..6da3efa 100644 --- a/lib/perfectqueue/backend/rdb.rb +++ b/lib/perfectqueue/backend/rdb.rb @@ -21,8 +21,8 @@ def initialize(uri, table, config={}) host: u.host, port: u.port ? u.port.to_i : 3306 } - @pq_connect_timeout = config.fetch(:pq_connect_timeout, 20) - options[:connect_timeout] = config.fetch(:connect_timeout, 3) + @pq_connect_timeout = config.fetch(:pq_connect_timeout, 120) + options[:connect_timeout] = config.fetch(:connect_timeout, 30) options[:sslca] = config[:sslca] if config[:sslca] db_name = u.path.split('/')[1] @db = Sequel.mysql2(db_name, options) diff --git a/lib/perfectqueue/backend/rdb_compat.rb b/lib/perfectqueue/backend/rdb_compat.rb index 15e820f..eda019e 100644 --- a/lib/perfectqueue/backend/rdb_compat.rb +++ b/lib/perfectqueue/backend/rdb_compat.rb @@ -42,7 +42,7 @@ class Token < Struct.new(:key) def initialize(client, config) super - @pq_connect_timeout = config.fetch(:pq_connect_timeout, 20) + @pq_connect_timeout = config.fetch(:pq_connect_timeout, 120) url = config[:url] @table = config[:table] unless @table @@ -51,7 +51,7 @@ def initialize(client, config) if /\Amysql2:/i =~ url options = {max_connections: 1, sslca: config[:sslca]} - options[:connect_timeout] = config.fetch(:connect_timeout, 3) + options[:connect_timeout] = config.fetch(:connect_timeout, 30) @db = Sequel.connect(url, options) if config.fetch(:use_connection_pooling, nil) != nil @use_connection_pooling = !!config[:use_connection_pooling]