github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

test output plugin vs worker params

Browse source 
Fixes #2876
This commit is contained in:
Joao Duarte 2015-03-24 10:09:39 +00:00 • committed by Jordan Sissel
parent b12d5feb13
commit cd85dd081d
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
spec/outputs/base_spec.rb
View file

@ -6,6 +6,8 @@ class LogStash::Outputs::NOOP < LogStash::Outputs::Base
config_name "noop"
milestone 2
config :dummy_option, :validate => :string
def register; end
def receive(event)
@ -13,6 +15,16 @@ class LogStash::Outputs::NOOP < LogStash::Outputs::Base
end
end
describe "LogStash::Outputs::Base#worker_setup" do
it "should create workers using original parameters except workers = 1" do
params = { "dummy_option" => "potatoes", "codec" => "json", "workers" => 2 }
worker_params = params.dup; worker_params["workers"] = 1
output = LogStash::Outputs::NOOP.new(params.dup)
expect(LogStash::Outputs::NOOP).to receive(:new).twice.with(worker_params).and_call_original
output.worker_setup
end
end
describe "LogStash::Outputs::Base#output?" do
it "should filter by type" do
output = LogStash::Outputs::NOOP.new("type" => "noop")