Class: LogStash::Inputs::Azure::ProcessorFactory

Inherits:

Object

Object
LogStash::Inputs::Azure::ProcessorFactory

Defined in:: lib/logstash/inputs/processor_factory.rb

Instance Method Summary collapse

#createEventProcessor(context) ⇒ Object
#initialize(queue, codec, checkpoint_interval, decorator, meta_data) ⇒ ProcessorFactory constructor

A new instance of ProcessorFactory.

Constructor Details

#initialize(queue, codec, checkpoint_interval, decorator, meta_data) ⇒ `ProcessorFactory`

Returns a new instance of ProcessorFactory.

# 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

Instance Method Details

#createEventProcessor(context) ⇒ `Object`



18
19
20

# File 'lib/logstash/inputs/processor_factory.rb', line 18

def createEventProcessor(context)
  Processor.new(@queue, @codec.clone, @checkpoint_interval, @decorator, @meta_data)
end