Class: Telekinesis::Consumer::BaseProcessor

Inherits:

Object

• Object
• Telekinesis::Consumer::BaseProcessor

Defined in:

lib/telekinesis/consumer/base_processor.rb

Overview

A RecordProcessor with no-op implementations of all of the required IRecordProcessor methods. Override it to implement simple IRecordProcessors that don’t need to do anything special on init or shutdown.

Direct Known Subclasses

Block

Instance Method Summary

• #init(initialization_input) ⇒ Object
• #process_records(process_records_input) ⇒ Object
• #shutdown(shutdown_input) ⇒ Object

Instance Method Details

#init(initialization_input) ⇒ Object

# File 'lib/telekinesis/consumer/base_processor.rb', line 7

def init(initialization_input); end

#process_records(process_records_input) ⇒ Object

# File 'lib/telekinesis/consumer/base_processor.rb', line 8

def process_records(process_records_input); end

#shutdown(shutdown_input) ⇒ Object

# File 'lib/telekinesis/consumer/base_processor.rb', line 9

def shutdown(shutdown_input); end