in_newsyslog.rb in fluent-plugin-newsyslog-0.1.2

- old
+ new

@@ -1,5 +1,7 @@
+require 'fluent/input'
+
 module Fluent
   class NewSyslogInput < Input
     Plugin.register_input('newsyslog', self)
 
     FACILITY_MAP = {
@@ -70,10 +72,12 @@
       @parser = TextParser::NewSyslogParser.new
       @parser.configure(conf)
     end
 
     def start
+      super
+
       @loop = Coolio::Loop.new
       @handler = listen(method(:receive_data))
       @loop.attach(@handler)
 
       @thread = Thread.new(&method(:run))
@@ -82,10 +86,12 @@
     def shutdown
       @loop.watchers.each {|w| w.detach }
       @loop.stop
       @handler.close
       @thread.join
+
+      super
     end
 
     def run
       @loop.run(@blocking_timeout)
     rescue
@@ -135,6 +141,6 @@
     rescue => e
       log.error "syslog failed to emit", :error => e.to_s, :error_class => e.class.to_s, :tag => tag, :record => Yajl.dump(record)
     end
 
   end
-end
\ No newline at end of file
+end