lib/marvin/distributed/drb_client.rb in Sutto-marvin-0.2.1 vs lib/marvin/distributed/drb_client.rb in Sutto-marvin-0.2.2

- old
+ new

@@ -60,11 +60,11 @@ def enter_loop! Marvin::Logger.info "Entering processing loop" while !self.stopped begin unless self.ring_server.blank? - event = self.ring_server.take([:marvin_event, nil, nil, nil], 5) - dispatch(*event[1..-1]) unless event.blank? + event = self.ring_server.take([:marvin_event, Marvin::Settings.distributed_namespace, nil, nil, nil], 2) + dispatch(*event[2..-1]) unless event.blank? end rescue # Reset the ring server on event of connection refused etc. @ring_server = nil end \ No newline at end of file