mirror of https://github.com/reiseburo/hermann
14 lines
312 B
Ruby
14 lines
312 B
Ruby
# Produce messages for a given amount of time
|
|
|
|
require 'rubygems'
|
|
require 'lib/hermann'
|
|
require 'lib/hermann/consumer'
|
|
|
|
stopTime = Time.now + 60 # One minute from now
|
|
p = Hermann::Producer.new("lms_messages")
|
|
count = 0
|
|
while(Time.now < stopTime)
|
|
p.push("Message_#{count}")
|
|
count = count + 1
|
|
end
|
|
puts("Done!") |