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