File tree Expand file tree Collapse file tree 2 files changed +2
-9
lines changed Expand file tree Collapse file tree 2 files changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -26,15 +26,14 @@ module Resque
26
26
# 1. A 'hostname:port' string
27
27
# 2. A 'hostname:port:db' string (to select the Redis db)
28
28
# 3. An instance of `Redis`
29
- # 4. An instance of `DistRedis`
30
29
def redis = ( server )
31
30
case server
32
31
when String
33
32
host , port , db = server . split ( ':' )
34
33
redis = Redis . new ( :host => host , :port => port ,
35
34
:thread_safe => true , :db => db )
36
35
@redis = Redis ::Namespace . new ( :resque , :redis => redis )
37
- when Redis , DistRedis
36
+ when Redis
38
37
@redis = Redis ::Namespace . new ( :resque , :redis => server )
39
38
else
40
39
raise "I don't know what to do with #{ server . inspect } "
@@ -230,8 +229,7 @@ def info
230
229
# Returns an array of all known Resque keys in Redis. Redis' KEYS operation
231
230
# is O(N) for the keyspace, so be careful - this can be slow for big databases.
232
231
def keys
233
- redis_keys = redis . keys ( "*" ) . flatten
234
- redis_keys . map do |key |
232
+ redis . keys ( "*" ) . map do |key |
235
233
key . sub ( 'resque:' , '' )
236
234
end
237
235
end
Original file line number Diff line number Diff line change 1
1
require File . dirname ( __FILE__ ) + '/test_helper'
2
- # require 'dist_redis'
3
2
4
3
context "Resque" do
5
4
setup do
10
9
Resque . push ( :people , { 'name' => 'mark' } )
11
10
end
12
11
13
- # test "can use DistRedis" do
14
- # assert Resque.redis = DistRedis.new({:hosts => ['localhost:9736', 'localhost:9736']})
15
- # end
16
-
17
12
test "can put jobs on a queue" do
18
13
assert Resque ::Job . create ( :jobs , 'SomeJob' , 20 , '/tmp' )
19
14
assert Resque ::Job . create ( :jobs , 'SomeJob' , 20 , '/tmp' )
You can’t perform that action at this time.
0 commit comments