mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
parent
a007926fde
commit
67e2ca354d
2 changed files with 4 additions and 6 deletions
|
@ -330,7 +330,10 @@ module LogStash; class JavaPipeline < JavaBasePipeline
|
|||
# @param plugins [Array[Plugin]] the list of plugins to register
|
||||
def register_plugins(plugins)
|
||||
registered = []
|
||||
plugins.each { |plugin| registered << @lir_execution.registerPlugin(plugin) }
|
||||
plugins.each do |plugin|
|
||||
plugin.register
|
||||
registered << plugin
|
||||
end
|
||||
rescue => e
|
||||
registered.each(&:do_close)
|
||||
raise e
|
||||
|
|
|
@ -79,11 +79,6 @@ public final class CompiledPipeline {
|
|||
return inputs;
|
||||
}
|
||||
|
||||
public RubyIntegration.Plugin registerPlugin(final RubyIntegration.Plugin plugin) {
|
||||
plugin.register();
|
||||
return plugin;
|
||||
}
|
||||
|
||||
/**
|
||||
* This method contains the actual compilation of the {@link Dataset} representing the
|
||||
* underlying pipeline from the Queue to the outputs.
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue