Contents

# encoding: utf-8
require "logstash/util/loggable"
require_relative "read_mode/processor"

module FileWatch
  class ObservingRead
    include LogStash::Util::Loggable
    include ObservingBase

    def subscribe(observer)
      # observer here is the file input
      watch.subscribe(observer, sincedb_collection)
      sincedb_collection.write("read mode subscribe complete - shutting down")
    end

    private

    def build_specific_processor(settings)
      ReadMode::Processor.new(settings)
    end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-input-file-4.1.2	lib/filewatch/observing_read.rb
logstash-input-file-4.1.1	lib/filewatch/observing_read.rb
logstash-input-file-4.1.0	lib/filewatch/observing_read.rb