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

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

Instance Attribute Summary collapse

Instance Method Summary collapse

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