Class: Logstash::Inputs::DynamoDB::LogStashRecordProcessorFactory

Inherits:

Object

Object
Logstash::Inputs::DynamoDB::LogStashRecordProcessorFactory

show all

Includes:: KCL::IRecordProcessorFactory

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

Instance Method Summary collapse

#create_processor ⇒ Object
#initialize(queue) ⇒ LogStashRecordProcessorFactory constructor

A new instance of LogStashRecordProcessorFactory.

Constructor Details

#initialize(queue) ⇒ `LogStashRecordProcessorFactory`

Returns a new instance of LogStashRecordProcessorFactory.



32
33
34

# File 'lib/logstash/inputs/LogStashRecordProcessorFactory.rb', line 32

def initialize(queue)
  @queue ||= queue
end

Instance Method Details

#create_processor ⇒ `Object`



36
37
38

# File 'lib/logstash/inputs/LogStashRecordProcessorFactory.rb', line 36

def create_processor
  return Logstash::Inputs::DynamoDB::LogStashRecordProcessor.new(@queue)
end