server: handle messages in dedicated context of celluloid internal pool

niamster · Feb 22, 2015 · 6d1ea2e · 6d1ea2e
1 parent d4d5ecf
commit 6d1ea2e
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/lib/dcell/server.rb b/lib/dcell/server.rb
@@ -29,10 +29,12 @@ def handle_message(message)
         return
       end
 
-      begin
-        message.dispatch
-      rescue => ex
-        Logger.crash("message dispatch failed", ex)
+      Celluloid::Future.new do
+        begin
+          message.dispatch
+        rescue => ex
+          Logger.crash("message dispatch failed", ex)
+        end
       end
     end
 
@@ -72,7 +74,7 @@ def initialize(cell)
     # Wait for incoming 0MQ messages
     def run
       while true
-        async.handle_message @socket.read
+        handle_message @socket.read
       end
     end
   end