Method: Upperkut::Strategies::BufferedQueue#fetch_items

Defined in:
lib/upperkut/strategies/buffered_queue.rb

#fetch_items ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/upperkut/strategies/buffered_queue.rb', line 41

def fetch_items
  stop = [@batch_size, size].min

  items = redis do |conn|
    conn.multi do
      stop.times { conn.lpop(key) }
    end
  end

  decode_json_items(items)
end