lib/resque_bus/local.rb in resque-bus-0.2.5 vs lib/resque_bus/local.rb in resque-bus-0.2.6

- old
+ new

@@ -19,10 +19,10 @@ end end # looking directly at subscriptions loaded into dispatcher # so we don't need redis server up - def self.subscription_matches(attributes) + def subscription_matches(attributes) out = [] ResqueBus.dispatchers.each do |dispatcher| out.concat(dispatcher.subscription_matches(attributes)) end out