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