class Fuzzy::MegateufIn
Public Instance Methods
register()
click to toggle source
# File lib/fuzzy/megateuf_in.rb, line 12 def register end
run(queue)
click to toggle source
# File lib/fuzzy/megateuf_in.rb, line 16 def run(queue) c = 1 loop do queue << LogStash::Event.new({ "message" => "#{c} Megateuf"}) c += 1 sleep(1) break if stop? end end