search for: feed_fetch_limit

...def fill_feed_queue last_at = 0 @queue = SizedQueue.new(10) # with a capacity for 10 # we do the queue filling in a single thread that runs until no more items are left to add Thread.new do loop do logger.debug("Fetching next block of feeds: limit = #{FEED_FETCH_LIMIT}, offset = #{last_at}") feeds = Feed.find(:all, :limit => FEED_FETCH_LIMIT, :offset => last_at) break if feeds == nil || feeds.length == 0 last_at += feeds.length # add each feed found to the queue feeds.each do |feed| fee...