diff --git a/lib/fluent/plugin/out_bufferize.rb b/lib/fluent/plugin/out_bufferize.rb index 87fd555..2987cb8 100644 --- a/lib/fluent/plugin/out_bufferize.rb +++ b/lib/fluent/plugin/out_bufferize.rb @@ -89,9 +89,9 @@ def configure(conf) raise ConfigError, "Befferize: just one directive is required" end - type = configs.first['type'] + type = configs.first['type'] || configs.first['@type'] unless type - raise ConfigError, "Befferize: 'type' parameter is required in directive" + raise ConfigError, "Befferize: '@type' parameter is required in directive" end @output = Plugin.new_output(type) @@ -104,8 +104,8 @@ def start end def shutdown - super @output.shutdown + super end def format(tag, time, record)