Contents

module Telekinesis
  module Consumer
    # 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.
    class BaseProcessor
      def init(shard_id); end
      def process_records(records, checkpointer); end
      def shutdown(checkpointer, reason); end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
telekinesis-2.0.1-java	lib/telekinesis/consumer/base_processor.rb
telekinesis-2.0.0-java	lib/telekinesis/consumer/base_processor.rb