We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent aa6ac0a commit 70ae9d0Copy full SHA for 70ae9d0
test/multi_queue_test.rb
@@ -31,6 +31,16 @@
31
assert_equal [bar, job], queue.pop(true)
32
end
33
34
+ it "nonblocking pop doesn't block" do
35
+ foo = Resque::Queue.new 'foo', redis, coder
36
+ bar = Resque::Queue.new 'bar', redis, coder
37
+ queue = Resque::MultiQueue.new([foo, bar], redis)
38
+
39
+ assert_raises ThreadError do
40
+ queue.pop(true)
41
+ end
42
43
44
it "blocks forever on pop" do
45
foo = Resque::Queue.new 'foo', redis, coder
46
bar = Resque::Queue.new 'bar', redis, coder
0 commit comments