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