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

remove explicit clone set up on output workers

Browse source 
Fixes #2876
This commit is contained in:
Joao Duarte 2015-03-24 10:28:51 +00:00 • committed by Jordan Sissel
parent e5ba35e0c7
commit 4a3c9e7be5
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/outputs/base.rb
View file

@ -69,7 +69,7 @@ class LogStash::Outputs::Base < LogStash::Plugin
else
define_singleton_method(:handle, method(:handle_worker))
@worker_queue = SizedQueue.new(20)
@worker_plugins = @workers.times.map { self.class.new(@original_params.merge("workers" => 1, "codec" => @codec.clone)) }
@worker_plugins = @workers.times.map { self.class.new(@original_params.merge("workers" => 1)) }
@worker_plugins.map.with_index do |plugin, i|
Thread.new(original_params, @worker_queue) do |params, queue|
LogStash::Util::set_thread_name(">#{self.class.config_name}.#{i}")