worker.rb in ruote-2.1.9

- old
+ new

@@ -64,11 +64,11 @@
       end
     end
 
     def run_in_thread
 
-      Thread.abort_on_exception = true
+      #Thread.abort_on_exception = true
         # TODO : remove me at some point
 
       @running = true
 
       @run_thread = Thread.new { run }
@@ -226,13 +226,12 @@
 
         elsif EXP_ACTIONS.include?(action)
 
           Ruote::Exp::FlowExpression.do_action(@context, msg)
 
-        elsif action == 'dispatch'
+        elsif action.match(/^dispatch/)
 
-          #dispatch(msg)
-          @context.dispatch_pool.dispatch(msg)
+          @context.dispatch_pool.handle(msg)
 
         elsif PROC_ACTIONS.include?(action)
 
           self.send(action, msg)
 