Sha256: 478728920d48c5bd658d0d28ef55846351a56b56200f2abb91d12aea1dc8c96b
Contents?: true
Size: 698 Bytes
Versions: 62
Compression:
Stored size: 698 Bytes
Contents
module ::LogStash; module Plugins; module Builtin; module Pipeline; class Output < ::LogStash::Outputs::Base
include org.logstash.plugins.pipeline.PipelineOutput
config_name "pipeline"
concurrency :shared
config :send_to, :validate => :string, :required => true, :list => true
config :ensure_delivery, :validate => :boolean, :default => true
attr_reader :pipeline_bus
def register
@pipeline_bus = execution_context.agent.pipeline_bus
pipeline_bus.registerSender(self, @send_to)
end
def multi_receive(events)
pipeline_bus.sendEvents(self, events, ensure_delivery)
end
def close
pipeline_bus.unregisterSender(self, @send_to)
end
end; end; end; end; end
Version data entries
62 entries across 62 versions & 1 rubygems