Class: FileWatch::ObservingRead

Inherits:

Object

• Object
• FileWatch::ObservingRead

Includes:

ObservingBase, LogStash::Util::Loggable

Defined in:

lib/filewatch/observing_read.rb

Instance Attribute Summary

Attributes included from ObservingBase

#settings, #sincedb_collection, #watch

Instance Method Summary

• #subscribe(observer) ⇒ Object

Methods included from ObservingBase

#build_watch_and_dependencies, #initialize, #quit, #sincedb_write, #watch_this

Instance Method Details

#subscribe(observer) ⇒ Object

# File 'lib/filewatch/observing_read.rb', line 10

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