Method: Upperkut::Strategies::BufferedQueue#push_items

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

#push_items(items = []) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
 
# File 'lib/upperkut/strategies/buffered_queue.rb', line 30

def push_items(items = [])
  items = [items] if items.is_a?(Hash)
  return false if items.empty?

  redis do |conn|
    conn.rpush(key, encode_json_items(items))
  end

  true
end