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

@@ -1,32 +1,34 @@
 module ResqueBus
   # only process local queues
   class Local
 
-    def self.perform(attributes = {})
-      ResqueBus.log_worker("Local running: #{attributes.inspect}")
+    class << self
+      def perform(attributes = {})
+        ResqueBus.log_worker("Local running: #{attributes.inspect}")
 
-      # looking for subscriptions, not queues
-      subscription_matches(attributes).each do |sub|
-         bus_attr = {"bus_driven_at" => Time.now.to_i, "bus_rider_queue" => sub.queue_name, "bus_rider_app_key" => sub.app_key, "bus_rider_sub_key" => sub.key, "bus_rider_class_name" => sub.class_name}
-        to_publish = bus_attr.merge(attributes || {})
-        if ResqueBus.local_mode == :standalone
-          ResqueBus.enqueue_to(sub.queue_name, sub.class_name, bus_attr.merge(attributes || {}))
-        # defaults to inline mode
-        else ResqueBus.local_mode == :inline
-          sub.execute!(to_publish)
+        # looking for subscriptions, not queues
+        subscription_matches(attributes).each do |sub|
+           bus_attr = {"bus_driven_at" => Time.now.to_i, "bus_rider_queue" => sub.queue_name, "bus_rider_app_key" => sub.app_key, "bus_rider_sub_key" => sub.key, "bus_rider_class_name" => sub.class_name}
+          to_publish = bus_attr.merge(attributes || {})
+          if ResqueBus.local_mode == :standalone
+            ResqueBus.enqueue_to(sub.queue_name, sub.class_name, bus_attr.merge(attributes || {}))
+          # defaults to inline mode
+          else ResqueBus.local_mode == :inline
+            sub.execute!(to_publish)
+          end
         end
       end
-    end
 
-    # looking directly at subscriptions loaded into dispatcher
-    # so we don't need redis server up
-    def self.subscription_matches(attributes)
-      out = []
-      ResqueBus.dispatchers.each do |dispatcher|
-        out.concat(dispatcher.subscription_matches(attributes))
+      # looking directly at subscriptions loaded into dispatcher
+      # so we don't need redis server up
+      def self.subscription_matches(attributes)
+        out = []
+        ResqueBus.dispatchers.each do |dispatcher|
+          out.concat(dispatcher.subscription_matches(attributes))
+        end
+        out
       end
-      out
     end
 
   end
 end