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