Class: LogStash::Plugins::Builtin::Pipeline::Output

Inherits:
Outputs::Base show all
Defined in:
lib/logstash/plugins/builtin/pipeline/output.rb

Constant Summary

Constants included from Config::Mixin

Config::Mixin::PLUGIN_VERSION_0_9_0, Config::Mixin::PLUGIN_VERSION_1_0_0

Constants included from Util::SubstitutionVariables

Util::SubstitutionVariables::SUBSTITUTION_PLACEHOLDER_REGEX

Constants inherited from LogStash::Plugin

LogStash::Plugin::NL

Instance Attribute Summary collapse

Attributes included from Config::Mixin

#config, #original_params

Attributes inherited from LogStash::Plugin

#execution_context, #params

Instance Method Summary collapse

Methods inherited from Outputs::Base

#codec, #concurrency, concurrency, declare_threadsafe!, declare_workers_not_supported!, #execution_context=, #initialize, plugin_type, #receive, threadsafe?, #workers_not_supported

Methods included from Config::Mixin

#config_init, included

Methods included from Util::SubstitutionVariables

#deep_replace, #replace_placeholders

Methods included from Util::Loggable

included, #logger, #slow_logger

Methods inherited from LogStash::Plugin

#config_name, #debug_info, #do_close, #eql?, #hash, #id, #initialize, #inspect, lookup, #metric, #metric=, #reloadable?, reloadable?, #to_s

Constructor Details

This class inherits a constructor from LogStash::Outputs::Base

Instance Attribute Details

#pipeline_bus ⇒ Object (readonly)

Returns the value of attribute pipeline_bus.



12
13
14
 
# File 'lib/logstash/plugins/builtin/pipeline/output.rb', line 12

def pipeline_bus
  @pipeline_bus
end

Instance Method Details

#close ⇒ Object 



23
24
25
 
# File 'lib/logstash/plugins/builtin/pipeline/output.rb', line 23

def close
  pipeline_bus.unregisterSender(self, @send_to)
end

#multi_receive(events) ⇒ Object 



19
20
21
 
# File 'lib/logstash/plugins/builtin/pipeline/output.rb', line 19

def multi_receive(events)
  pipeline_bus.sendEvents(self, events, ensure_delivery)
end

#register ⇒ Object 



14
15
16
17
 
# File 'lib/logstash/plugins/builtin/pipeline/output.rb', line 14

def register
  @pipeline_bus = execution_context.agent.pipeline_bus
  pipeline_bus.registerSender(self, @send_to)
end