lib/racecar/consumer_set.rb in racecar-2.8.2 vs lib/racecar/consumer_set.rb in racecar-2.9.0.beta1
- old
+ new
@@ -138,10 +138,10 @@
remain_ms = 1
elsif try == 0 && remain_ms == 0
@logger.debug "No time remains for polling messages. Will try on next call."
return nil
elsif wait_ms >= remain_ms
- @logger.error "Only #{remain_ms}ms left, but want to wait for #{wait_ms}ms before poll. Will retry on next call."
+ @logger.warn "Only #{remain_ms}ms left, but want to wait for #{wait_ms}ms before poll. Will retry on next call."
@previous_retries = try
return nil
elsif wait_ms > 0
sleep wait_ms/1000.0
remain_ms -= wait_ms