kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

update comments from blpop to brpop

Browse source
This commit is contained in:
awaw fumin 2014-03-05 19:04:32 +08:00
parent 8dae3840a3
commit 426caabe55
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/sidekiq/fetch.rb
View file

@ -140,10 +140,10 @@ module Sidekiq
end end
end end
# Creating the Redis#blpop command takes into account any # Creating the Redis#brpop command takes into account any
# configured queue weights. By default Redis#blpop returns # configured queue weights. By default Redis#brpop returns
# data from the first queue that has pending elements. We # data from the first queue that has pending elements. We
# recreate the queue command each time we invoke Redis#blpop # recreate the queue command each time we invoke Redis#brpop
# to honor weights and avoid queue starvation. # to honor weights and avoid queue starvation.
def queues_cmd def queues_cmd
queues = @strictly_ordered_queues ? @unique_queues.dup : @queues.shuffle.uniq queues = @strictly_ordered_queues ? @unique_queues.dup : @queues.shuffle.uniq