lib/fluent/plugin/in_systemd.rb in fluent-plugin-systemd-0.0.3 vs lib/fluent/plugin/in_systemd.rb in fluent-plugin-systemd-0.0.4

@@ -1,6 +1,7 @@
 require "systemd/journal"
+require "fluent/input"
 require "fluent/plugin/systemd/pos_writer"
 
 module Fluent
   class SystemdInput < Input
     Fluent::Plugin.register_input("systemd", self)
@@ -29,9 +30,10 @@
       pos_writer.start
       @thread = Thread.new(&method(:run))
     end
 
     def shutdown
+      super
       @running = false
       @thread.join
       pos_writer.shutdown
     end