spec/inputs/elasticsearch_spec.rb in logstash-input-elasticsearch-4.0.3 vs spec/inputs/elasticsearch_spec.rb in logstash-input-elasticsearch-4.0.4

@@ -166,10 +166,10 @@
                 docinfo_target => '#{metadata_field}'
               }
             }
         ]
 
-        pipeline = LogStash::Pipeline.new(config_metadata_with_string)
+        pipeline = new_pipeline_from_string(config_metadata_with_string)
         queue = Queue.new
         pipeline.instance_eval do
           @output_func = lambda { |event| queue << event }
         end