Moving event queue initialization

jaimeiniesta · Aug 27, 2011 · f73efdf · f73efdf
1 parent a0fa24f
commit f73efdf
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/lib/alondra.rb b/lib/alondra.rb
@@ -54,6 +54,10 @@ class Alondra < Rails::Engine
 
       Server.die_gracefully_on_signal
     end
+
+    initializer "start event queue" do
+      EventQueue.push({}) # start push socket as soon as possible
+    end
   end
 end
 

diff --git a/lib/alondra/event_queue.rb b/lib/alondra/event_queue.rb
@@ -12,9 +12,6 @@ def self.push(event)
 
     def initialize
       Rails.logger.debug "Starting event queue"
-
-      send({}) # start push socket as soon as possible
-
       start if ENV['ALONDRA_SERVER'].present?
     end
 
@@ -44,7 +41,7 @@ def parse(received_string)
       elsif received_hash[:message]
         message = Message.new(received_hash[:content])
       else
-        Rails.logger.error "Not recognized message type #{received.copy_out_string}"
+        Rails.logger.warn "Not recognized message type #{received_string}"
       end
     end