Sha256: 09805855a0e9e0aa474b18e7be65cb623a829942875ace7302d74058bf798b33

Contents?: true

Size: 328 Bytes

Versions: 22

Compression:

Stored size: 328 Bytes

Contents

# encoding: utf-8
class InfiniteGelfProducer
  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

22 entries across 22 versions & 2 rubygems

Version Path
logstash-input-gelf-3.3.2 spec/support/helpers.rb
logstash-input-gelf-3.3.1 spec/support/helpers.rb
logstash-input-gelf-3.3.0 spec/support/helpers.rb
logstash-input-gelf-3.2.0 spec/support/helpers.rb
logstash-input-gelf-3.1.1 spec/support/helpers.rb
logstash-input-gelf-3.1.0 spec/support/helpers.rb
logstash-input-gelf-3.0.7 spec/support/helpers.rb
logstash-input-gelf-3.0.6 spec/support/helpers.rb
logstash-input-gelf-3.0.5 spec/support/helpers.rb
logstash-input-gelf-3.0.4 spec/support/helpers.rb
logstash-input-gelfx-1.0.1 spec/support/helpers.rb
logstash-input-gelfx-1.0.0 spec/support/helpers.rb
logstash-input-gelf-2.0.8 spec/support/helpers.rb
logstash-input-gelf-3.0.2 spec/support/helpers.rb
logstash-input-gelf-3.0.1 spec/support/helpers.rb
logstash-input-gelf-3.0.0 spec/support/helpers.rb
logstash-input-gelf-2.0.7 spec/support/helpers.rb
logstash-input-gelf-2.0.5 spec/support/helpers.rb
logstash-input-gelf-2.0.3 spec/support/helpers.rb
logstash-input-gelf-2.0.2 spec/support/helpers.rb