class LogStash::Inputs::Azure::ProcessorFactory
Public Class Methods
new(queue, codec, checkpoint_interval, decorator, meta_data)
click to toggle source
# File lib/logstash/inputs/processor_factory.rb, line 10 def initialize(queue, codec, checkpoint_interval, decorator, meta_data) @queue = queue @codec = codec @checkpoint_interval = checkpoint_interval @decorator = decorator @meta_data = meta_data end
Public Instance Methods
createEventProcessor(context)
click to toggle source
# File lib/logstash/inputs/processor_factory.rb, line 18 def createEventProcessor(context) Processor.new(@queue, @codec.clone, @checkpoint_interval, @decorator, @meta_data) end