lib/fluent/plugin/in_ping_message.rb in fluent-plugin-ping-message-0.2.0 vs lib/fluent/plugin/in_ping_message.rb in fluent-plugin-ping-message-0.2.1

@@ -1,5 +1,6 @@
+require 'fluent/input'
 require 'fluent/mixin/config_placeholders'
 
 class Fluent::PingMessageInput < Fluent::Input
   Fluent::Plugin.register_input('ping_message', self)
 
@@ -14,10 +15,10 @@
   config_param :interval, :integer, :default => 60
   config_param :data, :string, :default => `hostname`.chomp
 
   # Define `router` method of v0.12 to support v0.10.57 or earlier
   unless method_defined?(:router)
-    define_method("router") { Engine }
+    define_method("router") { Fluent::Engine }
   end
 
   def start
     super
     start_pingloop