We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bf24bc2 commit 5a6f5fbCopy full SHA for 5a6f5fb
lib/redis_client/cluster/pub_sub.rb
@@ -65,7 +65,7 @@ def next_event(timeout = nil)
65
loop do
66
break if max_duration > 0 && obtain_current_time - starting > max_duration
67
68
- @states.each_value do |pubsub|
+ @states.values.shuffle.each do |pubsub|
69
message = pubsub.take_message(timeout)
70
return message if message
71
end
0 commit comments