grow the filter queue when we have more workers

Eric013 · Jul 11, 2012 · 48375c1 · 48375c1
1 parent 187f164
commit 48375c1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/logstash/agent.rb b/lib/logstash/agent.rb
@@ -394,7 +394,7 @@ def run_with_config(config)
       end
 
       # NOTE(petef) we should have config params for queue size
-      @filter_queue = LogStash::SizedQueue.new(10)
+      @filter_queue = LogStash::SizedQueue.new(10 * @filterworker_count)
       @filter_queue.logger = @logger
       @output_queue = LogStash::MultiQueue.new
       @output_queue.logger = @logger