Skip to content

Commit eef9dc5

Browse files
committed
move queue registration to the constructor
1 parent 81ec222 commit eef9dc5

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

lib/resque/queue.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,12 @@ def initialize name, redis, coder = Marshal
2020
@redis_name = "queue:#{@name}"
2121
@redis = redis
2222
@coder = coder
23+
24+
@redis.sadd(:queues, @name)
2325
end
2426

2527
# Add +object+ to the queue
2628
def push object
27-
@redis.sadd(:queues, @name)
28-
2929
synchronize do
3030
@redis.rpush @redis_name, encode(object)
3131
end

test/worker_test.rb

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
include Test::Unit::Assertions
55

66
before do
7+
Resque.redis = Resque.redis # reset state in Resque object
78
Resque.redis.flushall
89

910
Resque.before_first_fork = nil

0 commit comments

Comments
 (0)