out_rename_key.rb in fluent-plugin-rename-key-0.1.4

- old
+ new

@@ -1,12 +1,18 @@
 class Fluent::RenameKeyOutput < Fluent::Output
   Fluent::Plugin.register_output 'rename_key', self
 
+  DEFAULT_APPEND_TAG = 'key_renamed'
+
   config_param :remove_tag_prefix, :string, default: nil
-  config_param :append_tag, :string, default: 'key_renamed'
+  config_param :append_tag, :string, default: DEFAULT_APPEND_TAG
   config_param :deep_rename, :bool, default: true
 
+  unless method_defined?(:router)
+    define_method("router") { Fluent::Engine }
+  end
+
   def configure conf
     super
 
     @rename_rules = []
     conf_rename_rules = conf.keys.select { |k| k =~ /^rename_rule(\d+)$/ }
@@ -33,10 +39,10 @@
   def emit tag, es, chain
     es.each do |time, record|
       new_tag = @remove_tag_prefix ? tag.sub(@remove_tag_prefix, '') : tag
       new_tag = "#{new_tag}.#{@append_tag}".sub(/^\./, '')
       new_record = rename_key record
-      Fluent::Engine.emit new_tag, time, new_record
+      router.emit new_tag, time, new_record
     end
 
     chain.next
   end
 