Sha256: e02dda64e9c5860497dbdab1b1223b568f505e0a2d3cad81b5eef01461c14523
Contents?: true
Size: 896 Bytes
Versions: 5
Compression:
Stored size: 896 Bytes
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/outputs/zeromq"
require_relative "support/client"
module ZeroMQHelpers
def setup_clients(number_of_clients, port)
number_of_clients.times.inject([]) do |clients|
clients << ZeroMQClient.new(localhost, port)
end
end
def output(config, size, &block)
plugin = LogStash::Plugin.lookup("output", "zeromq").new(config)
plugin.register
events = []
size.times do |n|
events << LogStash::Event.new({"message" => "data #{n}"})
end
pipeline_thread = Thread.new { plugin.multi_receive(events) }
sleep 0.3
result = block.call
plugin.close
pipeline_thread.join
result
end # def input
end
RSpec.configure do |config|
config.include ZeroMQHelpers
# config.filter_run_excluding({ :zeromq => true, :integration => true })
config.order = :random
end
Version data entries
5 entries across 5 versions & 1 rubygems