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