We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2763666 commit 7658284Copy full SHA for 7658284
lib/resque/plugins/round_robin/round_robin.rb
@@ -30,7 +30,9 @@ def should_work_on_queue? queuename
30
max = DEFAULT_QUEUE_DEPTH
31
max = ENV["RESQUE_QUEUE_DEPTH"].to_i if ENV["RESQUE_QUEUE_DEPTH"].present?
32
return true if max == 0 # 0 means no limiting
33
- return true if queue_depth(queuename) < max
+ cur_depth = queue_depth(queuename)
34
+ log! "queue #{queuename} depth = #{cur_depth} max = #{max}"
35
+ return true if cur_depth < max
36
false
37
end
38
lib/resque/plugins/round_robin/version.rb
@@ -1,7 +1,7 @@
1
module Resque
2
module Plugins
3
module RoundRobin
4
- VERSION = "0.1.1"
+ VERSION = "0.1.2"
5
6
7
0 commit comments