File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
lib/resque/plugins/round_robin Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -24,9 +24,10 @@ def queue_depth queuename
24
24
busy_queues . select { |q | q == queuename } . size
25
25
end
26
26
27
+ DEFAULT_QUEUE_DEPTH = 0
27
28
def should_work_on_queue? queuename
28
29
return true if @queues . include? '*' # workers with QUEUES=* are special and are not subject to queue depth setting
29
- max = 1 # by default, workers are limited to 1 per queue
30
+ max = DEFAULT_QUEUE_DEPTH
30
31
max = ENV [ "RESQUE_QUEUE_DEPTH" ] . to_i if ENV [ "RESQUE_QUEUE_DEPTH" ] . present?
31
32
return true if max == 0 # 0 means no limiting
32
33
return true if queue_depth ( queuename ) < max
Original file line number Diff line number Diff line change 1
1
module Resque
2
2
module Plugins
3
3
module RoundRobin
4
- VERSION = "0.1.0 "
4
+ VERSION = "0.1.1 "
5
5
end
6
6
end
7
7
end
You can’t perform that action at this time.
0 commit comments