Contents

# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/inputs/zeromq"
require_relative "support/client"

class ZeroMQHelpers

  def input(config, size, &block)
    plugin = LogStash::Plugin.lookup("input", "zeromq").new(config)
    plugin.register
    queue  = Queue.new

    pipeline_thread = Thread.new { plugin.run(queue) }
    sleep 0.3
    block.call
    sleep 0.1 while queue.size != size
    result = size.times.inject([]) do |acc|
      acc << queue.pop
    end
    plugin.do_stop
    pipeline_thread.join
    result
  end # def input

end

RSpec.configure do |config|
  # config.filter_run_excluding({ :zeromq => true, :integration => true })
  config.order = :random
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-input-zeromq-3.0.5	spec/spec_helper.rb
logstash-input-zeromq-3.0.3	spec/spec_helper.rb
logstash-input-zeromq-3.0.0	spec/spec_helper.rb