Method: ZSpec::Queue#enqueue

Defined in:
lib/zspec/queue.rb

#enqueue(messages) ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/zspec/queue.rb', line 31

def enqueue(messages)
  messages.each do |message|
    @sink.lpush(@pending_queue_name, message)
    @sink.incr(@counter_name)
  end
  @sink.set(@workers_ready_key_name, true)
end