Run should not be private

jgwmaxwell · Mar 23, 2011 · 2816950 · 2816950
1 parent cb7c525
commit 2816950
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 19 deletions.
diff --git a/lib/minion.rb b/lib/minion.rb
@@ -119,6 +119,23 @@ def logger(&block)
     @logging = block
   end
 
+  # Runs the minion subscribers.
+  #
+  # @example Run the subscribers.
+  #   Minion.run
+  def run
+    info("Starting minion")
+    Signal.trap("INT") { AMQP.stop { EM.stop } }
+    Signal.trap("TERM") { AMQP.stop { EM.stop } }
+
+    EM.run do
+      AMQP.start(amqp_config) do
+        MQ.prefetch(1)
+        check_handlers
+      end
+    end
+  end
+
   # Get the url for the amqp server.
   #
   # @example Get the url.
@@ -211,22 +228,5 @@ def error_handling
   def logging
     @logging ||= ->(msg) { puts("#{Time.now} :minion: #{msg}") }
   end
-
-  # Runs the minion subscribers.
-  #
-  # @example Run the subscribers.
-  #   Minion.run
-  def run
-    info("Starting minion")
-    Signal.trap("INT") { AMQP.stop { EM.stop } }
-    Signal.trap("TERM") { AMQP.stop { EM.stop } }
-
-    EM.run do
-      AMQP.start(amqp_config) do
-        MQ.prefetch(1)
-        check_handlers
-      end
-    end
-  end
 end
 
diff --git a/lib/minion/handler.rb b/lib/minion/handler.rb
@@ -7,11 +7,11 @@ def initialize(queue)
       @sub = lambda {}
       @unsub = lambda {}
       @on = false
-      end
+    end
 
     def should_sub?
       @when.call
-      end
+    end
 
     def check
       if should_sub?