lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.8.6 vs lib/dispatch-rider/demultiplexer.rb in dispatch-rider-1.9.0
- old
+ new
@@ -16,9 +16,10 @@
end
def start
do_loop do
begin
+ sleep 1
handle_next_queue_item
rescue => exception
error_handler.call(Message.new(subject: "TopLevelError", body: {}), exception)
throw :done
end