Skip to content

Commit 5b86880

Browse files
committed
extract redis creation
1 parent 6191c07 commit 5b86880

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

lib/resque.rb

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -60,27 +60,29 @@ def create_connection(server = Resque.server)
6060
else
6161
server, namespace = server.split('/', 2)
6262
host, port, db = server.split(':')
63-
redis = Redis.new(:host => host, :port => port,
64-
:thread_safe => true, :db => db)
63+
redis = create_redis(host, port, db)
6564
end
6665
namespace ||= :resque
6766

6867
Redis::Namespace.new(namespace, :redis => redis)
6968
when Redis::Namespace
7069
Redis::Namespace.new(server.namespace,
71-
:redis => Redis.new(:host => server.redis.client.host,
72-
:port => server.redis.client.port,
73-
:db => server.redis.client.db,
74-
:thread_safe => true))
70+
:redis => create_redis(server.client.host, server.client.port, server.client.db))
7571
else
7672
Redis::Namespace.new(:resque,
77-
:redis => Redis.new(:host => server.client.host,
78-
:port => server.client.port,
79-
:db => server.client.db,
80-
:thread_safe => true))
73+
:redis => create_redis(server.client.host, server.client.port, server.client.db))
8174
end
8275
end
8376

77+
def create_redis(host, port, db)
78+
require 'logger'
79+
Redis.new(:host => host,
80+
:port => port,
81+
:db => db,
82+
:thread_safe => true,
83+
:logger => Logger.new(STDOUT))
84+
end
85+
8486
def server
8587
@server
8688
end

0 commit comments

Comments
 (0)