Contents

# encoding: utf-8
class InfiniteDelfProducer
  def initialize(host, port, chunksize)
    @client = GELF::Notifier.new(host, port, chunksize)
  end

  def run
    @producer = Thread.new do
      while true
        @client.notify!("short_message" => "hello world")
      end
    end
  end

  def stop
    @producer.kill
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-input-delf-3.2	spec/support/helpers.rb
logstash-input-delf-3.1.3	spec/support/helpers.rb
logstash-input-delf-3.0.3	spec/support/helpers.rb